def __default_args()

in liminal/runners/airflow/dag/liminal_register_dags.py [0:0]

• 8 lines of code
• 3 McCabe index (conditional complexity)

def __default_args(pipeline):
    default_args = {k: v for k, v in pipeline.items()}
    override_args = {
        'start_date': datetime.combine(pipeline['start_date'], datetime.min.time()),
        __DEPENDS_ON_PAST: default_args[__DEPENDS_ON_PAST] if __DEPENDS_ON_PAST in default_args else False,
    }
    default_args.update(override_args)
    return default_args