Skip to content

Skipped EmptyOperator task logs are giving 404 error #53002

@atul-astronomer

Description

@atul-astronomer

Apache Airflow version

3.0.3rc4

If "Other Airflow 2 version" selected, which one?

No response

What happened?

Skipped EmptyOperator task logs are giving 404 error

Image

Behaviour in 3.0-4

Image

What you think should happen instead?

No response

How to reproduce

Have a dag which has EmptyOperator which is supposed to be skipped:

from datetime import datetime

from airflow import Dataset
from airflow.decorators import dag
from airflow.providers.standard.operators.python import BranchPythonOperator
from airflow.providers.standard.operators.empty import EmptyOperator

# these two will have downstream dags
left = Dataset("left")
right = Dataset("right")


@dag(start_date=datetime(1970, 1, 1), schedule=None)
def branch_empty():
    l = EmptyOperator(task_id="left", outlets=[left])
    c = EmptyOperator(task_id="center", outlets=[])
    r = EmptyOperator(task_id="right", outlets=[right])
    BranchPythonOperator(
        task_id="decide", python_callable=lambda: ["left", "center"]
    ) >> [l, c, r]


branch_empty()

Operating System

Linux

Versions of Apache Airflow Providers

No response

Deployment

Other

Deployment details

No response

Anything else?

No response

Are you willing to submit PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Metadata

Labels

area:UIRelated to UI/UX. For Frontend Developers.area:corearea:loggingkind:bugThis is a clearly a bugpriority:mediumBug that should be fixed before next release but would not block a release

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions