Sha256: 9345f88ee80609c695cd23c27ce88bb59aa702ada7c6e07bf096765ab13931c7

Contents?: true

Size: 210 Bytes

Versions: 2

Compression:

Stored size: 210 Bytes

Contents

from datetime import datetime

from tasks import multiply

now = datetime.now()
run_at = now.replace(second = (now.second + 5) % 60)

result = multiply.apply_async(args=[5,5], eta=run_at)
print result.get(10)

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
rcelery-1.0.1 spec/integration/python_components/celery_deferred_client.py
rcelery-1.0.0 spec/integration/python_components/celery_deferred_client.py