GitHub user gopidesupavan added a comment to the discussion: dependencies between assets in airflow
There is likely issue with `include_prior_dates` that was fixed lastweek, https://github.com/apache/airflow/pull/53809 it should be available in next release. Can you try without `include_prior_dates` is it working? on 3.0.3 BTW i tested your example on main branch its working fine. not with S3 similar i mimicked ``` from airflow.sdk import asset, Asset, Context from airflow.providers.amazon.aws.hooks.s3 import S3Hook import json @asset( uri="s3://csv/users.json", schedule="@daily", group='test' ) def user(self): s3_path = self.uri.replace("s3://", "") bucket, key = s3_path.split("/", 1) return {"name": "John Doe", "age": 30, "location": "New York"} @asset( schedule=user, ) def user_location(self, context: Context, user: Asset) -> dict[str]: user_data = context['ti'].xcom_pull( dag_id="user", task_ids="user", include_prior_dates=True ) print(f"User data pulled from XCom: {user_data}") return user_data ``` GitHub link: https://github.com/apache/airflow/discussions/54064#discussioncomment-13979750 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected]
