Skip to content

Commit 8ab5d98

Browse files
committed
Remove aws batch monitor
1 parent 2570804 commit 8ab5d98

3 files changed

Lines changed: 2 additions & 202 deletions

File tree

aws/utils/job_monitor.py

Lines changed: 0 additions & 135 deletions
This file was deleted.

batch_monitor.py

Lines changed: 0 additions & 62 deletions
This file was deleted.

batch_submit.py

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
from pathlib import Path
88

99
from aws.run_job import AWSBatchJobLauncher
10-
from aws.utils.job_monitor import JobMonitor
1110
from codeclash.utils.log import get_logger
1211

1312
logger = get_logger("batch_submit", emoji="🚀")
@@ -27,7 +26,6 @@ def __init__(
2726
job_queue=job_queue,
2827
region=region,
2928
)
30-
self.monitor = JobMonitor(region=region)
3129

3230
def submit_configs(self, configs: list[str]) -> dict[str, dict[str, str]]:
3331
"""Submit jobs for a list of config files. Returns job_id -> {job_name, config} mapping."""
@@ -51,14 +49,13 @@ def save_job_ids(self, job_info: dict[str, dict[str, str]]) -> Path:
5149
return output_file
5250

5351
def run(self, configs: list[str]) -> None:
54-
"""Submit jobs, save IDs, and monitor."""
52+
"""Submit jobs and save IDs."""
5553
job_info = self.submit_configs(configs)
5654
self.save_job_ids(job_info)
57-
self.monitor.monitor(job_info)
5855

5956

6057
def main() -> None:
61-
parser = argparse.ArgumentParser(description="Submit multiple AWS Batch jobs and monitor them")
58+
parser = argparse.ArgumentParser(description="Submit multiple AWS Batch jobs")
6259
parser.add_argument("configs_file", type=Path, help="Text file containing config file names (one per line)")
6360
parser.add_argument(
6461
"--config-dir",

0 commit comments

Comments
 (0)