Session ( ) - database sessionĬlassmethod get_many ( cls, execution_date : pendulum.DateTime, key : Optional = None, task_ids : Optional ] ] = None, dag_ids : Optional ] ] = None, include_prior_dates : bool = False, limit : Optional = None, session : Session = None ) ¶Ĭomposes a query to get one or more values from the xcom table. Include_prior_dates ( bool) - If False, only XCom from the currentĮxecution_date are returned. If None (default), the DAG of the calling task is used. Can pass None to remove the filter.ĭag_id ( str) - If provided, only pulls XCom from this DAG. Task_id ( str) - Only XComs from task with matching id will be Returns NoneĮxecution_date ( pendulum.datetime) - Execution date for the task Retrieve an XCom value, optionally meeting certain criteria. None classmethod get_one ( cls, execution_date : pendulum.DateTime, key : Optional = None, task_id : Optional ] ] = None, dag_id : Optional ] ] = None, include_prior_dates : bool = False, session : Session = None ) ¶ _repr_ ( self ) ¶ classmethod set ( cls, key, value, execution_date, task_id, dag_id, session = None ) ¶ I.e automatically deserialize Xcom value when loading from DB. _tablename_ = xcom ¶ key ¶ value ¶ timestamp ¶ execution_date ¶ task_id ¶ dag_id ¶ init_on_load ( self ) ¶Ĭalled by the ORM after the instance has been loaded from the DB or otherwise reconstituted BaseXCom ¶īases:, _mixin.LoggingMixinīase class for XCom objects.
0 kommentar(er)
