In meinem DAG muss ich basierend auf dem logischen Datum der DAG-Ausführung unterschiedliche Bedingungen für Dateien definieren. Ich möchte direkt als Python-Datum/Uhrzeit-Objekt in meinem Skript auf das logische Datum zugreifen, damit ich if-Bedingungen und andere Datumsvergleiche durchführen kann.
Für jede Tabelle möchte ich ein „Stichtag“ definieren: Vor diesem Datum sollte ein Pfad verwendet werden, und ab diesem Datum sollte ein anderer Pfad verwendet werden.
Ist es möglich, das logische Datum auf diese Weise aus Airflow abzurufen – als datetime-Variable – statt nur einer Jinja-Vorlagenzeichenfolge?
Debuggen von Luftstromvariablen ⇐ Python
-
- Similar Topics
- Replies
- Views
- Last post
Mobile version