Skip to content

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: