Ryuu10/05/2023, 10:53 AM
I have regist this task succesfull, when i try to run this task. I have test locally and successful use sensor infinity. But when run on remote, the task sensor is aborted and take this error from Flyte console UI.
from flytekit.sensor.file_sensor import FileSensor from flytekit import task, workflow from flytekit import Resources sensor = FileSensor(name="test_sensor") @task(limits=Resources(mem="10Mi")) def t1(): print("flyte") @workflow def wf() -> str: # sensor(path="/tmp/123") >> t1() task1 = sensor(path="/tmp/123") task2 = t1() task1 >> task2 if __name__ == "__main__": wf()
`Workflow[flytesnacks:development:<http://sensor_task.wf|sensor_task.wf>] failed. RuntimeExecutionError: max number of system retry attempts [11/10] exhausted. Last known status message: failed at Node[n0]. RuntimeExecutionError: failed during plugin execution, caused by: failed to execute handle for plugin [container]: [BadTaskSpecification] invalid TaskSpecification, unable to determine Pod configuration'
Kevin Su10/06/2023, 5:30 AM
tasks: task-plugins: enabled-plugins: - agent-service default-for-task-types: - sensor: agent-service