diff --git a/nitric/api/queues.py b/nitric/api/queues.py index 9ac808c..a002c8b 100644 --- a/nitric/api/queues.py +++ b/nitric/api/queues.py @@ -155,7 +155,9 @@ async def send( task = Task() if isinstance(task, dict): - # TODO: handle tasks that are just a payload + # Handle if its just a payload + if task.get("payload") is None: + task = {"payload": task} task = Task(**task) try: