Skip to content

Commit da7d880

Browse files
committed
refactor: Made task optional again in BaseTrigger
1 parent 32323b3 commit da7d880

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

  • airflow-core/src/airflow/triggers

airflow-core/src/airflow/triggers/base.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -90,8 +90,10 @@ def _set_context(self, context):
9090
pass
9191

9292
@property
93-
def task(self) -> Operator:
94-
return self.task_instance.task
93+
def task(self) -> Operator | None:
94+
if self.task_instance:
95+
return self.task_instance.task
96+
return None
9597

9698
@property
9799
def task_instance(self) -> TaskInstance | None:

0 commit comments

Comments
 (0)