Ryuu
10/05/2023, 10:53 AMfrom 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()
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.
`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'
Samhita Alla
Kevin Su
10/06/2023, 5:30 AMtasks:
task-plugins:
enabled-plugins:
- agent-service
default-for-task-types:
- sensor: agent-service