Skip to content

Commit a4cecc1

Browse files
fix: accept numpy arrays for JSON conversion on SQS
1 parent 7311f52 commit a4cecc1

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

‎taskqueue/aws_queue_api.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
import boto3
66
import botocore.errorfactory
77

8-
from .lib import toiter, sip
8+
from .lib import toiter, sip, jsonify
99
from .secrets import aws_credentials
1010
from .secrets import (
1111
AWS_DEFAULT_REGION
@@ -88,7 +88,7 @@ def insert(self, tasks, delay_seconds=0):
8888

8989
entries = [ {
9090
"Id": str(j),
91-
"MessageBody": json.dumps(task),
91+
"MessageBody": jsonify(task),
9292
"DelaySeconds": delay_seconds,
9393
} for j, task in enumerate(batch)
9494
]

0 commit comments

Comments
 (0)