kaxil commented on code in PR #62128:
URL: https://github.com/apache/airflow/pull/62128#discussion_r2834702516
##########
airflow-core/src/airflow/dag_processing/manager.py:
##########
@@ -1076,7 +1072,15 @@ def prepare_file_queue(self, known_files: dict[str,
set[DagFileInfo]]):
Note this method is only called when the file path queue is empty
"""
- self._parsing_start_time = time.perf_counter()
+ # We only emit metrics after processing all files in the queue. If
`self._parsing_start_time` is None
+ # when this method is called, no files have yet been added to the
queue so we shouldn't emit metrics.
+ if self._parsing_start_time:
Review Comment:
```suggestion
if self._parsing_start_time is not None:
```
to not have to worry about 0.0 and such
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
