jroachgolf84 commented on code in PR #73135: URL: https://github.com/apache/airflow/pull/73135#discussion_r4058559384
########## airflow-core/docs/core-concepts/task-state-store.rst: ########## @@ -152,6 +152,13 @@ Async counterparts of ``get``, ``set``, ``delete``, and ``clear`` for use inside Calling the synchronous ``get``/``set``/``delete``/``clear`` from inside an ``async`` task blocks the event loop and defeats the concurrency the coroutine was written for. Use the ``a``-prefixed methods there instead. +Using ``task_state_store`` inside a Trigger +------------------------------------------- + +A trigger belonging to a deferred task can read and write that task's state store from within ``run()``. The triggerer injects ``self.task_state_store`` before ``run()`` is called, scoped to the task instance that deferred, which is the same namespace the operator's ``execute()`` and ``execute_complete()`` see. It is not available during ``__init__`` or ``serialize()``, only from within ``run()``. Review Comment: Addressed in next commit! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
