"""
    Test zero length reduction in mapped task at runtime with calls to dagrun.verify_integrity
    """
    import logging
    from airflow.models import Variable
    Variable.set(key="arg1", value=[1, 2, 3])
    @task
    def task_1():