Estoy creando un Airflow DAG para mi trabajo de pythin. Estos trabajos crean archivos json en el depósito s3 con la fecha actual. Estoy planeando pasar la fecha como variable de entorno. ¿Es posible hacerlo? lo que estoy intentando está debajo

 recommendations = KubernetesPodOperator( namespace='data', image = "quay.io/comp/data-rp-recommender:0.1.1", name = "data-rp-recommender-run", task_id = "data-rp-recommender-task", dag = dag, get_logs = True, in_cluster = True, is_delete_operator_pod = False, volumes = [ Volume( name = 'etcctek', ) ], volume_mounts = [ VolumeMount( name = 'etcctek', mount_path = '/opt/docker/etc', sub_path = None, read_only = True ) ], env_vars = { 'DATE' : 'USER_PRECEDING_STATS_S3' : 's3a://ml/rp-recommendations/userPreceedingStats/int/DATE/json' 'NUGGET_CATEGORICALS_S3' : 's3a://ml/rp-recommendations/nuggetCategorials/int/DATE/json' 'PREREQUISITE_STATS_S3' : 's3a://ml/rp-recommendations/prerequisiteStats/int/DATE/json' 'USER_CURRENT_STATS_S3' : 's3a://ml/rp-recommendations/userCurrentStats/int/DATE/json' }, resources = { 'request_memory': '2048M', 'request_cpu': '1.5' } )

En el ejemplo anterior, quiero configurar env_vars para DATE como fecha actual y luego usar esa fecha actual en otras variables a continuación. Es mi primera vez en el flujo de aire y necesita ayuda.