The transaction is committed it will be unlocked. Query, you should ensure that any scheduling decisions are made in a single transaction – as soon as This will return zero or more DagRun rows that are row-level-locked with a “SELECT … FOR UPDATE” Return the next DagRuns that the scheduler should attempt to schedule. Session ( Session) – database session classmethod next_dagruns_to_examine ( cls, session : Session, max_number : Optional = None ) ¶ Reloads the current dagrun from the database Parameters It can be createdīy the scheduler (for regular runs) or by an external trigger _tablename_ = dag_run ¶ id ¶ dag_id ¶ execution_date ¶ start_date ¶ end_date ¶ _state ¶ run_id ¶ creating_job_id ¶ external_trigger ¶ run_type ¶ conf ¶ last_scheduling_decision ¶ dag_hash ¶ dag ¶ _table_args_ ¶ task_instances ¶ DEFAULT_DAGRUNS_TO_EXAMINE ¶ state ¶ is_backfill ¶ _repr_ ( self ) ¶ get_state ( self ) ¶ set_state ( self, state ) ¶ refresh_from_db ( self, session : Session = None ) ¶ DagRun ( dag_id : Optional = None, run_id : Optional = None, execution_date : Optional = None, start_date : Optional = None, external_trigger : Optional = None, conf : Optional = None, state : Optional = None, run_type : Optional = None, dag_hash : Optional = None, creating_job_id : Optional = None ) ¶īases:, _mixin.LoggingMixinĭagRun describes an instance of a Dag. Type of return for DagRun.task_instance_scheduling_decisions tis :List ¶ schedulable_tis :List ¶ changed_tis :bool ¶ unfinished_tasks :List ¶ finished_tasks :List ¶ class. _emit_duration_stats_for_finished_state._emit_true_scheduling_delay_stats_for_finished_state.
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |