next_kwargs value sometimes value NULL sometimes string `null`

[dstandish]

Body

When running a dag with airflow dags test i noticed that in some of the mapped tasks, next_kwargs were null and in others they were the string value null which doesn't seem right.

Dag code:

import pendulum
from airflow import DAG
from airflow.operators.python import PythonOperator

with DAG(dag_id='hello', start_date=pendulum.now().add(days=-2)) as dag:

    @dag.task
    def make_list():
        return list(map(lambda a: f'echo "{a!r}"', [1, 2, {'a': 'b'}]))

    def consumer(*args):
        print(repr(args))

    op = PythonOperator.partial(
        task_id='consumer',
        python_callable=consumer,
    ).expand(op_args=make_list())

cc @ashb @uranusjr

Committer

• I acknowledge that I am a maintainer/committer of the Apache Airflow project.

[github-actions]

This issue has been automatically marked as stale because it has been open for 365 days without any activity. There has been several Airflow releases since last activity on this issue. Kindly asking to recheck the report against latest Airflow version and let us know if the issue is reproducible. The issue will be closed in next 30 days if no further activity occurs from the issue author.