Skip to content

Commit ed3dec8

Browse files
authored
fix mypy type errors in elasticsearch provider for sqlalchemy 2 upgrade (apache#56818)
1 parent 5f3ed23 commit ed3dec8

File tree

1 file changed

+5
-9
lines changed

1 file changed

+5
-9
lines changed

providers/elasticsearch/src/airflow/providers/elasticsearch/log/es_task_handler.py

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -252,15 +252,11 @@ def _render_log_id(self, ti: TaskInstance | TaskInstanceKey, try_number: int) ->
252252
data_interval_end = self._clean_date(dag_run.data_interval_end)
253253
logical_date = self._clean_date(dag_run.logical_date)
254254
else:
255-
if dag_run.data_interval_start:
256-
data_interval_start = dag_run.data_interval_start.isoformat()
257-
else:
258-
data_interval_start = ""
259-
if dag_run.data_interval_end:
260-
data_interval_end = dag_run.data_interval_end.isoformat()
261-
else:
262-
data_interval_end = ""
263-
logical_date = dag_run.logical_date.isoformat()
255+
data_interval_start = (
256+
dag_run.data_interval_start.isoformat() if dag_run.data_interval_start else ""
257+
)
258+
data_interval_end = dag_run.data_interval_end.isoformat() if dag_run.data_interval_end else ""
259+
logical_date = dag_run.logical_date.isoformat() if dag_run.logical_date else ""
264260

265261
return log_id_template.format(
266262
dag_id=ti.dag_id,

0 commit comments

Comments
 (0)