models_tdag
mainsequence.client.models_tdag
DataUpdates
Bases: BaseModel
This class contains the update details of the table in the main sequence engine
__iter__()
Iterate over keys.
filter_df_by_latest_value(df)
:param df: :return:
DynamicTableDataSource
Bases: BasePydanticModel, BaseObjectOrm
model_dump_json(**json_dumps_kwargs)
Dump the current instance to a JSON string,
ensuring that the dependent related_resource is also properly dumped.
DynamicTableHelpers
get_update_statistics(hash_id)
Gets latest value from Hash_id
LocalTimeSerie
Bases: BasePydanticModel, BaseObjectOrm
get_data_between_dates_from_api(start_date=None, end_date=None, great_or_equal=None, less_or_equal=None, unique_identifier_list=None, columns=None, unique_identifier_range_map=None)
Helper function to make a single batch request (or multiple paged requests if next_offset).
get_metadatas_and_set_updates(local_time_series_ids, update_details_kwargs, update_priority_dict)
classmethod
{'local_hash_id__in': [{'local_hash_id': 'alpacaequitybarstest_97018e7280c1bad321b3f4153cc7e986', 'data_source_id': 1}, :param local_hash_id__in: :param multi_index_asset_symbols_filter: :param update_details_kwargs: :param update_priority_dict: :return:
post_data_frame_in_chunks(serialized_data_frame, chunk_size=50000, local_metadata=None, data_source=None, index_names=None, time_index_name='timestamp', overwrite=False)
classmethod
Sends a large DataFrame to a Django backend in multiple chunks.
:param serialized_data_frame: The DataFrame to upload. :param url: The endpoint URL (e.g. https://yourapi.com/upload-chunk/). :param chunk_size: Number of rows per chunk. :param local_metadata: General metadata dict you want to send with each chunk. :param data_source: Additional info about the source of the data. :param index_names: Index columns in the DataFrame. :param time_index_name: The column name used for time indexing. :param overwrite: Boolean indicating whether existing data should be overwritten.
verify_if_direct_dependencies_are_updated()
Response({ "error_on_update_dependencies": False, "updated": all_success, })
Scheduler
Bases: BasePydanticModel, BaseObjectOrm
stop_heart_beat()
Stop the heartbeat gracefully.
SourceTableConfiguration
Bases: BasePydanticModel, BaseObjectOrm