File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed
airflow-core/src/airflow/api_fastapi/logging Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change 1919import itertools
2020import json
2121import logging
22+ from datetime import datetime
2223
2324import pendulum
2425from fastapi import Request
@@ -157,7 +158,10 @@ async def log_action(
157158 logical_date_value = request .query_params .get ("logical_date" )
158159 if logical_date_value :
159160 try :
160- log .logical_date = pendulum .parse (logical_date_value , strict = False )
161+ logical_date = pendulum .parse (logical_date_value , strict = False )
162+ if not isinstance (logical_date , datetime ):
163+ raise ParserError
164+ log .logical_date = logical_date
161165 except ParserError :
162166 logger .exception ("Failed to parse logical_date from the request: %s" , logical_date_value )
163167 else :
You can’t perform that action at this time.
0 commit comments