#X?ddlZddlmZddlmZddlmZddlmZddlm Z gdZ Gd d eZ d ej d <eZ ddefdZe jjdZdS)N)Callable)Celery)Task) task_method) PeriodTask)queue period_taskrceZdZdZdS) EntanglementTN)__name__ __module__ __qualname__abstractN/granary/edev/quantum/lib/python3.11/site-packages/qubit/io/celery/__init__.pyr r sHHHrr zqubit.io.celery.configCELERY_CONFIG_MODULElambdafnct|tr|j}tjdsgtjd<tjdt|dz |||S)Ntasksi) isinstancertaskr __dict__getappendr)rperiodnames rr r s{"k"" W   # #G , ,+(* W%!((6D="d++ Irc tjD];}||j|j|jr0s  1 1 14&> !"H!MM"!MMMr