Skip to content

Commit dd108c1

Browse files
committed
fix sqs queue handling
1 parent 600f911 commit dd108c1

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

run.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ def generate_task_definition(AWS_PROFILE):
108108
}]
109109

110110
sqs = boto3.client('sqs')
111-
queue_name = get_queue_url(sqs)
111+
queue_name, dead_url = get_queue_url(sqs)
112112
task_definition['containerDefinitions'][0]['environment'] += [
113113
{
114114
'name': 'APP_NAME',
@@ -209,7 +209,8 @@ def get_or_create_queue(sqs):
209209
if dead_url is None:
210210
print("Creating DeadLetter queue")
211211
sqs.create_queue(QueueName=SQS_DEAD_LETTER_QUEUE)
212-
212+
time.sleep(WAIT_TIME)
213+
queue_url, dead_url = get_queue_url(sqs)
213214
response = sqs.get_queue_attributes(
214215
QueueUrl=dead_url, AttributeNames=["QueueArn"]
215216
)

0 commit comments

Comments
 (0)