Skip to content

Commit 23dd70d

Browse files
committed
Merge remote-tracking branch 'origin/main' into develop
2 parents e80f7c5 + bb8ac39 commit 23dd70d

3 files changed

Lines changed: 18 additions & 9 deletions

File tree

CHANGELOG.md

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,14 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
77

88
## [Unreleased]
99
### Added
10+
### Changed
11+
### Deprecated
12+
### Removed
13+
### Fixed
14+
### Security
15+
16+
## [0.8.0]
17+
### Added
1018
- [issues/150](https://github.com/podaac/bignbit/issues/150): Added support for mixed NRT & Standard collections with configurable regex.
1119
### Changed
1220
- [issues/173](https://github.com/podaac/bignbit/issues/173): Changed resource names (e.g. ECR repo name) to include deployment level prefixes. This allows for deploying multiple copies of bignbit to a single AWS account/venue.

bignbit/get_harmony_job_status.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -108,6 +108,10 @@ def check_harmony_job(
108108
harmony_client = utils.get_harmony_client(cmr_env)
109109
try:
110110
job_status = harmony_client.status(harmony_job_id)
111+
except (requests.exceptions.ConnectionError, requests.exceptions.Timeout) as exc:
112+
raise HarmonyTransientError(
113+
f'Harmony API returned a transient error checking status of job {harmony_job_id}: {exc}'
114+
) from exc
111115
except requests.exceptions.HTTPError as exc:
112116
if exc.response is not None and exc.response.status_code >= 500:
113117
raise HarmonyTransientError(
@@ -120,6 +124,10 @@ def check_harmony_job(
120124
# Check that the harmony job returned data to confirm that the job was successful
121125
try:
122126
result_urls = list(harmony_client.result_urls(harmony_job_id, link_type=LinkType.s3))
127+
except (requests.exceptions.ConnectionError, requests.exceptions.Timeout) as exc:
128+
raise HarmonyTransientError(
129+
f'Harmony API returned a transient error fetching result URLs for job {harmony_job_id}: {exc}'
130+
) from exc
123131
except requests.exceptions.HTTPError as exc:
124132
if exc.response is not None and exc.response.status_code >= 500:
125133
raise HarmonyTransientError(

terraform/state_machine_definition.tpl

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -331,21 +331,14 @@
331331
"Retry":[
332332
{
333333
"ErrorEquals":[
334-
"HarmonyJobIncompleteError"
334+
"HarmonyJobIncompleteError",
335+
"HarmonyTransientError"
335336
],
336337
"IntervalSeconds":${HarmonyJobStatusIntervalSeconds},
337338
"MaxAttempts":${HarmonyJobStatusMaxAttempts},
338339
"BackoffRate":${HarmonyJobStatusBackoffRate},
339340
"MaxDelaySeconds":${HarmonyJobStatusMaxDelaySeconds}
340341
},
341-
{
342-
"ErrorEquals":[
343-
"HarmonyTransientError"
344-
],
345-
"IntervalSeconds":2,
346-
"MaxAttempts":6,
347-
"BackoffRate":2
348-
},
349342
{
350343
"ErrorEquals":[
351344
"Lambda.ServiceException",

0 commit comments

Comments
 (0)