Asset and Xom in Docker image

[turbothiele]

Apache Airflow version

3.0.4

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

No response

What happened?

I'm using version 3.0.4 in a Docker container. This example no longer runs in version:

from airflow.sdk import asset

@asset(schedule="@daily")
def extracted_data():
return {"a": 1, "b": 2}

@asset(schedule=extracted_data)
def transformed_data(context):
data = context["ti"].xcom_pull(
dag_id="extracted_data",
task_ids="extracted_data",
key="return_value",
include_prior_dates=True,
)
return {k: v * 2 for k, v in data.items()}

@asset(schedule=transformed_data)
def loaded_data(context):
data = context["task_instance"].xcom_pull(
dag_id="transformed_data",
task_ids="transformed_data",
key="return_value",
include_prior_dates=True,
)
summed_data = sum(data.values())
print(f"Summed data: {summed_data}")

What you think should happen instead?

No response

How to reproduce

from airflow.sdk import asset

@asset(schedule="@daily")
def extracted_data():
return {"a": 1, "b": 2}

@asset(schedule=extracted_data)
def transformed_data(context):
data = context["ti"].xcom_pull(
dag_id="extracted_data",
task_ids="extracted_data",
key="return_value",
include_prior_dates=True,
)
return {k: v * 2 for k, v in data.items()}

@asset(schedule=transformed_data)
def loaded_data(context):
data = context["task_instance"].xcom_pull(
dag_id="transformed_data",
task_ids="transformed_data",
key="return_value",
include_prior_dates=True,
)
summed_data = sum(data.values())
print(f"Summed data: {summed_data}")

Operating System

Ubuntu 24 Docker Image

Versions of Apache Airflow Providers

No response

Deployment

Official Apache Airflow Helm Chart

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

• I agree to follow this project's Code of Conduct

[boring-cyborg[bot]]

Thanks for opening your first issue here! Be sure to follow the issue template! If you are willing to raise PR to address this issue please do so, no need to wait for approval.

[potiuk]

You have forgotten to mention how things do not work. There are no details in your issue that would even indicate what kind of problem you have. This example no longer runs in version: might mean plenty of things - including something wrong in your installation process.

Generally speaking you can still continue discussing it here - but if you want anyone to be able to help you, you need to describe whet your problem is.