Skip to content

Commit 445daee

Browse files
committed
Make submissions code tolerant of old dynamo records
1 parent 3b73f15 commit 445daee

File tree

1 file changed

+15
-1
lines changed

1 file changed

+15
-1
lines changed

aws/submissions.py

+15-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
import json
22
import os
33

4+
from globus_sdk import GlobusAPIError
5+
46
from dynamo_manager import DynamoManager
57
from automate_manager import AutomateManager
68
from utils import get_secret
@@ -19,8 +21,20 @@ def format_status_record(status:dict, automate_manager:AutomateManager) -> dict:
1921
status["submitter"],
2022
status["submission_time"])
2123

22-
automate_status = automate_manager.get_status(status['action_id'])
24+
automate_status = {
25+
"status": "Unknown",
26+
"details": {
27+
"description": "Unknown"
28+
}
29+
}
2330

31+
if 'action-id' in status:
32+
try:
33+
automate_status = automate_manager.get_status(status['action_id'])
34+
except GlobusAPIError:
35+
automate_status["details"]['description'] = "Flow not found"
36+
else:
37+
automate_status["details"]['description'] = "Submission prior to GlobusAutomate"
2438

2539
return {
2640
"source_id": status["source_id"],

0 commit comments

Comments
 (0)