Module Import alias ImportFrom alias Import alias Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults vararg kwarg body For NameStore Call NameLoad Call AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Str Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Num Index Num Expr Call AttributeLoad NameLoad attr Str Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Num Index Num If BoolOpAnd CompareIsNot NameLoad NameLoad CompareIsNot NameLoad NameLoad body Assign NameStore Dict Str Str Str NameLoad BinOpAdd NameLoad Num Num Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad TupleLoad Str NameLoad decorator_list
N/A N/A logging synapse.storage.prepare_database get_statements N/A ujson N/A logger N/A N/A logging getLogger __name__ N/A ALTER_TABLE ALTER TABLE events ADD COLUMN origin_server_ts BIGINT;CREATE INDEX events_ts ON events(origin_server_ts, stream_ordering); run_upgrade N/A N/A cur database_engine N/A args kwargs N/A N/A statement N/A get_statements N/A N/A ALTER_TABLE splitlines N/A N/A N/A N/A cur execute statement N/A N/A N/A cur execute SELECT MIN(stream_ordering) FROM events N/A rows N/A N/A cur fetchall N/A min_stream_id N/A N/A rows N/A 0 N/A 0 N/A N/A N/A cur execute SELECT MAX(stream_ordering) FROM events N/A rows N/A N/A cur fetchall N/A max_stream_id N/A N/A rows N/A 0 N/A 0 N/A N/A N/A min_stream_id None N/A max_stream_id None N/A N/A progress N/A target_min_stream_id_inclusive max_stream_id_exclusive rows_inserted min_stream_id N/A max_stream_id 1 0 N/A progress_json N/A N/A ujson dumps progress N/A sql INSERT into background_updates (update_name, progress_json) VALUES (?, ?) N/A sql N/A N/A database_engine convert_param_style sql N/A N/A N/A cur execute sql N/A event_origin_server_ts progress_json N/A