Skip to content

Commit 6196678

Browse files
committed
remove legacy code
1 parent ea9f9cd commit 6196678

File tree

2 files changed

+4
-7
lines changed

2 files changed

+4
-7
lines changed

compose_runner/aws_lambda/log_poll_handler.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,9 +17,9 @@
1717
def handler(event: Dict[str, Any], context: Any) -> Dict[str, Any]:
1818
request = LambdaRequest.parse(event)
1919
payload = request.payload
20-
artifact_prefix = payload.get("artifact_prefix") or payload.get("job_id")
20+
artifact_prefix = payload.get("artifact_prefix")
2121
if not artifact_prefix:
22-
message = "Request payload must include 'artifact_prefix' (or legacy 'job_id')."
22+
message = "Request payload must include 'artifact_prefix'."
2323
if request.is_http:
2424
return request.bad_request(message, status_code=400)
2525
raise KeyError(message)

compose_runner/aws_lambda/results_handler.py

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -27,11 +27,9 @@ def handler(event: Dict[str, Any], context: Any) -> Dict[str, Any]:
2727
bucket = os.environ[RESULTS_BUCKET_ENV]
2828
prefix = os.environ.get(RESULTS_PREFIX_ENV)
2929

30-
artifact_prefix = (
31-
payload.get("artifact_prefix") or payload.get("run_id") or payload.get("job_id")
32-
)
30+
artifact_prefix = payload.get("artifact_prefix")
3331
if not artifact_prefix:
34-
message = "Request payload must include 'artifact_prefix' (or legacy 'run_id')."
32+
message = "Request payload must include 'artifact_prefix'."
3533
if request.is_http:
3634
return request.bad_request(message, status_code=400)
3735
raise KeyError(message)
@@ -64,7 +62,6 @@ def handler(event: Dict[str, Any], context: Any) -> Dict[str, Any]:
6462

6563
body = {
6664
"artifact_prefix": artifact_prefix,
67-
"job_id": payload.get("job_id"),
6865
"artifacts": artifacts,
6966
"bucket": bucket,
7067
"prefix": key_prefix,

0 commit comments

Comments
 (0)