fixes USACE/cumulus#141

USACE · Oct 27, 2021 · 0924a0a · 0924a0a
1 parent a39d10b
commit 0924a0a
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/async_geoprocess/geoprocess_worker/worker.py b/async_geoprocess/geoprocess_worker/worker.py
@@ -21,7 +21,13 @@
 if CONFIG.AWS_ACCESS_KEY_ID is None:
     # Running in AWS
     # Using IAM Role for Credentials
-    CLIENT = boto3.resource('sqs')
+    if CONFIG.ENDPOINT_URL_SQS:
+        CLIENT = boto3.resource(
+            'sqs',
+            endpoint_url=CONFIG.ENDPOINT_URL_SQS
+        )
+    else:
+        CLIENT = boto3.resource('sqs')
 else:
     # Local Testing
     # ElasticMQ with Credentials via AWS_ environment variables