Passing a dict as an argument to a task

[miguelvalente]

Hey, again @farahats9. 'm trying to pass a dictionary as an argument to a scheduled task:

asd = {
    "x": 5,
    "y": 5
}

import json
task = PeriodicTask(
    schedule_model=schedule,
    name='Adding to 10',
    task='main.add',
    args=json.dumps(asd)
)

It's saved with a dict structure,

But on the receiving end only the keys are provided.

Is this a limitation imposed by sqlalchemy-celery-beat or by celery? Still not very sure where the line between the two is.

[miguelvalente]

never mind I'm an idiot. Forgot about kwargs for 30 minutes.

task = PeriodicTask(
    schedule_model=schedule,
    name='Adding to 10',
    task='main.add',
    kwargs=json.dumps(asd),
)