@pytest.mark.parametrize('test_input, expected', [('1 * * * *', crontab(minute='1', hour='*', day_of_month='*', month_of_year='*', day_of_week='*')), ('* 1 * * *', crontab(minute='*', hour='1', day_of_month='*', month_of_year='*', day_of_week='*')), ('* * 1 * *', crontab(minute='*', hour='*', day_of_month='1', month_of_year='*', day_of_week='*')), ('* * * 1 *', crontab(minute='*', hour='*', day_of_month='*', month_of_year='1', day_of_week='*')), ('* * * * 1', crontab(minute='*', hour='*', day_of_month='*', month_of_year='*', day_of_week='1')), ('*/10 */11 */12 */13 */14', crontab(minute='*/10', hour='*/11', day_of_month='*/12', month_of_year='*/13', day_of_week='*/14'))])
def test_build_celery_crontab(test_input, expected):
    cron_schedule = {'crontab': test_input}
    assert ((test_input, expected) == build_celery_schedule('workflow_crontab', cron_schedule))
@pytest.mark.parametrize('test_input, expected', [('1 * * * *', crontab(minute='1', hour='*', day_of_month='*', month_of_year='*', day_of_week='*')), ('* 1 * * *', crontab(minute='*', hour='1', day_of_month='*', month_of_year='*', day_of_week='*')), ('* * 1 * *', crontab(minute='*', hour='*', day_of_month='1', month_of_year='*', day_of_week='*')), ('* * * 1 *', crontab(minute='*', hour='*', day_of_month='*', month_of_year='1', day_of_week='*')), ('* * * * 1', crontab(minute='*', hour='*', day_of_month='*', month_of_year='*', day_of_week='1')), ('*/10 */11 */12 */13 */14', crontab(minute='*/10', hour='*/11', day_of_month='*/12', month_of_year='*/13', day_of_week='*/14'))])
def test_build_celery_crontab(test_input, expected):
    cron_schedule = {'crontab': test_input}
    assert ((test_input, expected) == build_celery_schedule('workflow_crontab', cron_schedule))