Skip to content

Commit 32323b3

Browse files
committed
refactor: Make sure start_from_trigger is not None to be able to start task directly in deferred mode
1 parent b7b6e7a commit 32323b3

1 file changed

Lines changed: 1 addition & 3 deletions

File tree

airflow-core/src/airflow/models/taskinstance.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1454,8 +1454,7 @@ def defer_task(self, session: Session = NEW_SESSION) -> bool:
14541454

14551455
context = self.get_template_context()
14561456

1457-
if self.task and self.task.expand_start_from_trigger(context=context):
1458-
start_trigger_args = self.task.expand_start_trigger_args(context=context)
1457+
if self.task and self.task.expand_start_from_trigger(context=context) and (start_trigger_args := self.task.expand_start_trigger_args(context=context)):
14591458
trigger_kwargs = start_trigger_args.trigger_kwargs or {}
14601459
timeout = self.task.start_trigger_args.timeout
14611460

@@ -1465,7 +1464,6 @@ def defer_task(self, session: Session = NEW_SESSION) -> bool:
14651464
else:
14661465
self.trigger_timeout = None
14671466

1468-
print(">>> Creating trigger from context start_trigger_args: {}".format(trigger_kwargs))
14691467
trigger_row = Trigger(
14701468
classpath=start_trigger_args.trigger_cls,
14711469
kwargs=trigger_kwargs,

0 commit comments

Comments
 (0)