a a j@sRddlZddlmZmZmZmZmZddlmZddl m Z m Z GdddZ dS)N)DictAnySetOptionalCallable)logger)set_i2c_call_context_clear_i2c_call_contextc @sBeZdZddZdeeeeeeee egdfe dddZ dS) TaskExecutorcCsdS)N)selfr r */var/aqua_controller/core/task_executor.py__init__szTaskExecutor.__init__N)taskdevicesavailable_devices on_get_resultreturncCs d|vr$td|dddS|dd}td|d|dd |dD]@}|d }|d }|r||r|||vsTtd |d dSqT|dD]d}|d } |d d}dd|D} || } z ztd|d t| ||d|dkr| | n^|dkrJ| | } | durr|durr|| | |n(td|d| d WWt dSWn|t y} zbt d|t d| d|d| d| tdt j ddWYd} ~ Wt dSd} ~ 00Wt qt 0qdS) Nactionsu&Задача без действий: nameuбезымяннаяFZNoNameu1Взято в обработку правило 'u' параметры: ''devicemethoduУстройство 'u}' не доступно или действие некорректно. Выполнение задания прервано.cSsi|]\}}|dvr||qS))rrr ).0kvr r r ?z-TaskExecutor.execute_task..u%Выполнение задания ')rrule_id operationsetgetu#Неизвестный метод 'u' для устройства 'u5Прервано выполнение правила u/Ошибка выполнения метода .(z): uТрассировка: )limitT)rdebugr"criticalloweritemsrr!warningr Exceptionerror traceback format_exc)r rrrrZ task_nameactionZdev_namer device_nameparamsrresulter r r execute_tasksL           " zTaskExecutor.execute_task)N) __name__ __module__ __qualname__rdictrstrrrrboolr5r r r r r sr ) r.typingrrrrr core.loggerrcore.resilient_i2c_busrr r r r r r  s