From 81e7ef789042b983cf83e50f57a89cc3c21e2dd1 Mon Sep 17 00:00:00 2001 From: Domenico Testa Date: Fri, 17 Apr 2020 14:16:45 +0200 Subject: [PATCH] Fixing worker polling logical issue --- app.py | 2 -- karaokeme_cdk/__init__.py | 0 karaokeme_cdk/karaokeme_cdk_stack.py | 9 --------- worker/separator.py | 5 +++-- 4 files changed, 3 insertions(+), 13 deletions(-) delete mode 100644 karaokeme_cdk/__init__.py delete mode 100644 karaokeme_cdk/karaokeme_cdk_stack.py diff --git a/app.py b/app.py index 7935f30..8cab1a5 100644 --- a/app.py +++ b/app.py @@ -10,8 +10,6 @@ import aws_cdk.aws_ecs_patterns as ecs_patterns import aws_cdk.aws_s3 as s3 import aws_cdk.aws_sqs as sqs -from karaokeme_cdk.karaokeme_cdk_stack import KaraokemeCdkStack - class BaseResources(core.Stack): def __init__(self, *args, **kwargs): diff --git a/karaokeme_cdk/__init__.py b/karaokeme_cdk/__init__.py deleted file mode 100644 index e69de29..0000000 diff --git a/karaokeme_cdk/karaokeme_cdk_stack.py b/karaokeme_cdk/karaokeme_cdk_stack.py deleted file mode 100644 index dc8abe5..0000000 --- a/karaokeme_cdk/karaokeme_cdk_stack.py +++ /dev/null @@ -1,9 +0,0 @@ -from aws_cdk import core - - -class KaraokemeCdkStack(core.Stack): - - def __init__(self, scope: core.Construct, id: str, **kwargs) -> None: - super().__init__(scope, id, **kwargs) - - # The code that defines your stack goes here diff --git a/worker/separator.py b/worker/separator.py index 5eb1513..81c3dde 100644 --- a/worker/separator.py +++ b/worker/separator.py @@ -19,7 +19,7 @@ MAX_AUDIO_DURATION = float(os.getenv('MAX_AUDIO_DURATION', 600.)) AUDIO_START_OFFSET = float(os.getenv('AUDIO_START_OFFSET', 0.)) OUTPUT_FILENAME_FORMAT = os.getenv('OUTPUT_FILENAME_FORMAT', '{instrument}.{codec}') QUEUE_NAME = os.getenv('QUEUE_NAME') -POLLING_INTERVAL = int(os.getenv('POLLING_INTERVAL', 5)) +POLLING_INTERVAL = int(os.getenv('POLLING_INTERVAL', 10)) OUTPUT_BUCKET_NAME = os.getenv('OUTPUT_BUCKET_NAME') OUTPUT_BUCKET_REGION= os.getenv('OUTPUT_BUCKET_REGION', 'eu-west-1') TRACKS_TABLE_NAME = os.getenv('TRACKS_TABLE_NAME') @@ -103,7 +103,8 @@ def poll_for_sqs_message(queue_name: str): finally: sqs.delete_message(QueueUrl=queue_url, ReceiptHandle=message['ReceiptHandle']) - Timer(5, poll_for_sqs_message, args=[queue_name]).start() + # Schedule the next poll operation + Timer(POLLING_INTERVAL, poll_for_sqs_message, args=[queue_name]).start() if __name__ == '__main__':