apparently the auth needs credentials to be generated

Author: lhr0909

slow_tasks.py

@@ -10,10 +10,19 @@
 from constants import AWS_REGION, OPENSEARCH_HOST
 from celery_app import celery_app
 
-service = 'es'
-credentials = boto3.Session().get_credentials()
-awsauth = AWS4Auth(credentials.access_key, credentials.secret_key, AWS_REGION, service, session_token=credentials.token)
 
+def get_opensearch_client():
+    service = 'es'
+    credentials = boto3.Session().get_credentials()
+    awsauth = AWS4Auth(credentials.access_key, credentials.secret_key, AWS_REGION, service, session_token=credentials.token)
+    opensearch_client = OpenSearch(
+        hosts = [{'host': OPENSEARCH_HOST, 'port': 443}],
+        http_auth = awsauth,
+        use_ssl = True,
+        verify_certs = True,
+        connection_class = RequestsHttpConnection
+    )
+    return opensearch_client
 
 
 device = "cuda" if torch.cuda.is_available() else "cpu"
@@ -46,13 +55,7 @@ def process_audio_stream(
     print(f'from realtime: {transcription_from_realtime}')
     print(f'whisper large: {transcription}')
 
-    search = OpenSearch(
-        hosts = [{'host': OPENSEARCH_HOST, 'port': 443}],
-        http_auth = awsauth,
-        use_ssl = True,
-        verify_certs = True,
-        connection_class = RequestsHttpConnection
-    )
+    search = get_opensearch_client()
 
     document = {
         'timestamp': datetime.utcfromtimestamp(timestamp).isoformat(),