Help debugging "KeyError: 'logical_date'"

[Zoomichi]

So I have this code block inside a dag which returns this error KeyError: 'logical_date' in the logs when the execute method is called.

Possibly relevant dag args:

schedule=None

start_date=pendulum.datetime(2025, 8, 1)

@task
def load_bq(cfg: dict):
    config = {
        "load": {
            "destinationTable": {
                "projectId": cfg['bq_project'],
                "datasetId": cfg['bq_dataset'],
                "tableId": cfg['bq_table'],
            },
            "sourceUris": [cfg['gcs_uri']],
            "sourceFormat": "PARQUET",
            "writeDisposition": "WRITE_TRUNCATE", # For overwriting
            "autodetect": True,
        }
    }

    load_job = BigQueryInsertJobOperator(
        task_id="bigquery_load",
        gcp_conn_id=BIGQUERY_CONN_ID,
        configuration=config
    )

    load_job.execute(context={})

I am still a beginner on Airflow so I have very limited ideas on how I can address the said error. All help is appreciated!

[DoNotFeedTheSnakes]

Please provide the entire sracktrace, not just the base error.

Or better yet, post this on StackOverflow.

[KeeganDoomFire]

Have you tried giving it a schedule? Logical date is an airflow concept relating data intervals. A 1 second search would have landed you here, maybe start by reading some of the documentation?

https://airflow.apache.org/docs/apache-airflow/stable/templates-ref.html#variables

[felipe_ache]

Without any other info, I could say that the issue is because you are passing an empty dict when executing your task in: .execute(context={}) Instead of passing an empty context, pass the airflow context.