Skip to content

Commit

Permalink
default queue name, updated README
Browse files Browse the repository at this point in the history
  • Loading branch information
danwagoner committed Jan 17, 2023
1 parent 36011e7 commit 525c949
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
6 changes: 4 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -2,5 +2,7 @@

A lambda that drops a queue item into a defines schedule queue for shoruken to process and create batch jobs.

## Variables
WIP
### Environment Variables
| variable name | description | type | default | required |
| --------------- | ----------------- | :----: | :-------: | :------: |
| SCHEDULED_QUEUE | name of the queue | string | scheduled | no |
4 changes: 1 addition & 3 deletions index.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,6 @@
import datetime
import os

scheduled_queue = os.environ.get('SCHEDULED_QUEUE')


def lambda_handler(event, context):
sqs = boto3.resource('sqs')
Expand All @@ -18,7 +16,7 @@ def lambda_handler(event, context):
"job_class": event,
"job_id": id,
"provider_job_id": None,
"queue_name": scheduled_queue,
"queue_name": os.environ.get('SCHEDULED_QUEUE', default='scheduled'),
"priority": None,
"arguments": [],
"executions": 0,
Expand Down

0 comments on commit 525c949

Please sign in to comment.