|
2 | 2 | from threading import Lock |
3 | 3 | from .metadata import new_run_metadata, RunStatus |
4 | 4 | from .worker import run_test |
5 | | -from .runner import run_tests |
| 5 | +from .runner import create_test_file, run_tests |
6 | 6 | from datetime import datetime, timezone |
7 | 7 | from email.utils import format_datetime |
8 | 8 | from copy import deepcopy |
@@ -31,13 +31,25 @@ def handle_run_request(self, |
31 | 31 | check_args.group = test_suite_name |
32 | 32 | check_args.overrides = overrides |
33 | 33 |
|
| 34 | + try: |
| 35 | + create_test_file(check_args) |
| 36 | + except Exception as e: |
| 37 | + return {"error": str(e)} |
| 38 | + |
34 | 39 | # Generate a "tracked" run when it is a result of a remote dispatch. |
35 | 40 | if machine_target: |
36 | 41 | return self.create_run(config_name, test_suite_name, base_args, |
37 | 42 | machine_target, overrides) |
38 | 43 |
|
39 | | - # Ochestrator node execution. |
40 | | - self.executor.submit(run_tests, check_args) |
| 44 | + def on_done(f): |
| 45 | + try: |
| 46 | + f.result() |
| 47 | + except Exception as e: |
| 48 | + print(f"Run failed: {e}") |
| 49 | + |
| 50 | + # Orchestrator node execution. |
| 51 | + future = self.executor.submit(run_tests, check_args) |
| 52 | + future.add_done_callback(on_done) |
41 | 53 | return None |
42 | 54 |
|
43 | 55 | def create_run(self, |
|
0 commit comments