Skip to content

Commit 02cdfa4

Browse files
committed
feat(task_runner): early inlets and outlets check
1 parent db1833b commit 02cdfa4

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

task-sdk/src/airflow/sdk/execution_time/task_runner.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -796,6 +796,9 @@ def _prepare(ti: RuntimeTaskInstance, log: Logger, context: Context) -> ToSuperv
796796

797797

798798
def _validate_task_inlets_and_outlets(*, ti: RuntimeTaskInstance, log: Logger) -> None:
799+
if not ti.task.inlets and not ti.task.outlets:
800+
return
801+
799802
SUPERVISOR_COMMS.send_request(msg=ValidateInletsAndOutlets(ti_id=ti.id), log=log)
800803
invalid_assets_resp = SUPERVISOR_COMMS.get_message()
801804
if TYPE_CHECKING:

0 commit comments

Comments
 (0)