# Path: tests/examples/user_code/worker.py
# @app.task(bind=True, max_retries=2)
# def function_test(self, retries, **kwargs):
#     if retries > self.request.retries:
#         raise self.retry(countdown=1)
#     return kwargs.get('result', 'this is the result')


from datetime import datetime
from .worker import function_test


function_test.delay(0, tuples=(1, 2, 3), lists=[1, 2, 3], dicts={'mess': None, True: 'clearly'})
function_test.delay(0, tuples=(1, True, {'mess': None}),
                    lists=[(1, 'rogério'), datetime.now()],

# Path: tests/examples/user_code/worker.py
# @app.task(bind=True, max_retries=2)
# def function_test(self, retries, **kwargs):
#     if retries > self.request.retries:
#         raise self.retry(countdown=1)
#     return kwargs.get('result', 'this is the result')


# Path: tests/examples/user_code/publisher_demo.py
from datetime import datetime
from .worker import function_test



function_test.delay(0, tuples=(1, 2, 3), lists=[1, 2, 3], dicts={'mess': None, True: 'clearly'})
function_test.delay(0, tuples=(1, True, {'mess': None}),
                    lists=[(1, 'rogério'), datetime.now()],

                    sets={1.1, False},