Hello,
I am using sqs-workers for handling long-term tasks and I faced an issue with sending tasks:
Here is my code snippet:
sqs = SQSEnv(session=boto_client.get_session()) queue = sqs.queue("dev-test-queue") async generate_task(request: Request): configuration_data = to_config(request) message_id = queue.add_job(job_name="exectute_task", config_data=configuration_data)
The point is queue.add_job(_) return message_id but message is not appeared under SQS queue.
Stack:
- fast-api 0.103.1
- boto3 1.28.49
- sqs-workers 0.5.12