scheduler
mainsequence.tdag.time_series.update.scheduler
SchedulerUpdater
start(debug=False, update_tree=True, break_after_one_update=False, raise_exception_on_error=False, update_extra_kwargs=None, run_head_in_main_process=False, force_update=False, sequential_update=False, update_only_tree=False, api_port=None)
Parameters:
Name | Type | Description | Default |
---|---|---|---|
debug
|
bool
|
If True, all dependencies of a time series run in the same process. Defaults to False. |
False
|
update_tree
|
bool or dict
|
If True, updates the tree of dependent tasks. |
True
|
break_after_one_update
|
bool
|
If True, the process stops after the first update cycle. Defaults to False. |
False
|
raise_exception_on_error
|
bool
|
If True, raises an exception on encountering an error during execution. Otherwise, errors are handled silently. Defaults to False. |
False
|
update_extra_kwargs
|
dict or None
|
Additional parameters (if any) to pass along when updating. Defaults to None. |
None
|
run_head_in_main_process
|
bool
|
If True, each "head" time series is run in the main scheduler process. Useful for debugging. Defaults to False. |
False
|
force_update
|
bool
|
If True, forces an update run even if it's not required. Defaults to False. |
False
|
sequential_update
|
bool
|
If True, runs each "head" time series one by one instead of in parallel. Defaults to False. |
False
|
update_only_tree
|
bool
|
If True, only the dependency tree is updated without fully processing every step. Defaults to False. |
False
|
api_port
|
int or None
|
The port on which any exposed APIs should run. If None, no API is exposed. Defaults to None. |
None
|
TimeSerieHeadUpdateActor
__init__(local_hash_id, data_source_id, scheduler, debug, update_tree, update_extra_kwargs, remote_table_hashed_name)
Parameters:
Name | Type | Description | Default |
---|---|---|---|
hash_id
|
|
required | |
scheduler
|
Scheduler
|
|
required |
debug
|
|
required | |
update_tree
|
|
required | |
update_extra_kwargs
|
|
required |
run_one_step_update(force_update=False, update_only_tree=False)
Main update Method for a time serie Head
set_data_source(pod_source=None, tdag_detached=False, override_all=False)
:param override_all: :return: