We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bc01259 commit 85bc0c5Copy full SHA for 85bc0c5
airflow-core/tests/unit/dag_processing/test_manager.py
@@ -520,7 +520,9 @@ def test_scan_stale_dags(self, testing_dag_bundle):
520
521
def test_kill_timed_out_processors_kill(self):
522
manager = DagFileProcessorManager(max_runs=1, processor_timeout=5)
523
- processor, _ = self.mock_processor(start_time=16000)
+ # Set start_time to ensure timeout occurs: start_time = current_time - (timeout + 1) = always (timeout + 1) seconds
524
+ start_time = time.monotonic() - manager.processor_timeout - 1
525
+ processor, _ = self.mock_processor(start_time=start_time)
526
manager._processors = {
527
DagFileInfo(
528
bundle_name="testing", rel_path=Path("abc.txt"), bundle_path=TEST_DAGS_FOLDER
0 commit comments