Skip to content

Commit eb55723

Browse files
author
yolo h8cker 93
committed
Fix(aws): log group name
1 parent 819c693 commit eb55723

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

aws/run_job.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -114,17 +114,17 @@ def get_job_logs(self, job_id: str) -> str | None:
114114
latest_attempt = attempts[-1]
115115
container_info = latest_attempt.get("container", {})
116116
log_stream_name = container_info.get("logStreamName")
117+
logger.debug(f"Log stream name: {log_stream_name}")
117118

118119
if not log_stream_name:
119120
logger.warning("No log stream found for this job")
120121
return None
121122

122-
# Extract log group name from the log stream name
123-
# Format is typically: <log-group>/<stream-name>
124-
log_group_name = log_stream_name.split("/")[0]
123+
# AWS Batch logs are typically in the /aws/batch/job log group
124+
log_group_name = "/aws/batch/job"
125+
logger.debug(f"Log group name: {log_group_name}")
125126

126127
response = self.logs_client.get_log_events(logGroupName=log_group_name, logStreamName=log_stream_name)
127-
128128
return "\n".join(event["message"] for event in response["events"])
129129

130130

0 commit comments

Comments
 (0)