Are there any example of how to use Flytekit.Senso...
# ask-the-communityr
Ryuu
10/04/2023, 7:43 AMAre there any example of how to use Flytekit.Sensor ?
l
L godlike
10/04/2023, 9:04 AM Copy code
from flytekit.sensor.file_sensor import FileSensor
from flytekit import task, workflow
sensor = FileSensor(name="test_sensor")
@task()
def t1():
print("flyte")
@workflow
def wf():
sensor(path="/tmp/123") >> t1()
if __name__ == "__main__":
wf()r
Ryuu
10/04/2023, 11:11 AMThis is the example about The Sensor extend BaseSensor. I have read the git i saw about SensorEngine Which registed to Agent. Is this different than base_sensor
l
L godlike
10/04/2023, 11:11 AMYes it is different
L godlike
10/04/2023, 11:12 AMYou can print the value in sensor engine, and you will know how it works.
r
Ryuu
10/05/2023, 9:36 AMWorkflow[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 configurationRyuu
10/05/2023, 9:42 AMor maybe 10 attemps for another bugs
l
L godlike
10/05/2023, 12:14 PMmaybe it's about config map cc @Kevin Su
k
Kevin Su
10/05/2023, 5:59 PMI’m writing to the doc, sorry
Kevin Su
10/05/2023, 5:59 PMdid you deploy an agent in your cluster?