diff --git a/app/aws/s3.py b/app/aws/s3.py index 7f96f0c73..54c9c85a3 100644 --- a/app/aws/s3.py +++ b/app/aws/s3.py @@ -5,7 +5,6 @@ import time from io import StringIO import botocore -import eventlet from boto3 import Session from flask import current_app @@ -250,7 +249,7 @@ def get_s3_files(): for object_key in object_keys: read_s3_file(bucket_name, object_key, s3res) count = count + 1 - eventlet.sleep(0.2) + time.sleep(0.2) except Exception: current_app.logger.exception( f"Trouble reading {object_key} which is # {count} during cache regeneration" @@ -411,7 +410,7 @@ def get_job_from_s3(service_id, job_id): ) retries += 1 sleep_time = backoff_factor * (2**retries) # Exponential backoff - eventlet.sleep(sleep_time) + time.sleep(sleep_time) continue else: # Typically this is "NoSuchKey" diff --git a/app/celery/tasks.py b/app/celery/tasks.py index 0108981df..3a6a997b0 100644 --- a/app/celery/tasks.py +++ b/app/celery/tasks.py @@ -1,6 +1,6 @@ import json +import time -import eventlet from celery.signals import task_postrun from flask import current_app from requests import HTTPError, RequestException, request @@ -84,7 +84,7 @@ def process_job(job_id, sender_id=None): process_row(row, template, job, service, sender_id=sender_id) count = count + 1 if count % 3 == 0: - eventlet.sleep(1) + time.sleep(1) # End point/Exit point for message send flow. job_complete(job, start=start) diff --git a/app/clients/cloudwatch/aws_cloudwatch.py b/app/clients/cloudwatch/aws_cloudwatch.py index 9eaf2ebec..0a6d3d7be 100644 --- a/app/clients/cloudwatch/aws_cloudwatch.py +++ b/app/clients/cloudwatch/aws_cloudwatch.py @@ -151,7 +151,7 @@ class AwsCloudwatchClient(Client): # result = temp_client.get_query_results(queryId=query_id) # if result['status'] == 'Complete': # break - # eventlet.sleep(1) + # time.sleep(1) # delivery_receipts = [] # for log in result['results']: