Are there any example of how to use Flytekit.Senso...
# flyte-supportf
full-evening-87657
10/04/2023, 7:43 AMAre there any example of how to use Flytekit.Sensor ?
d
damp-lion-88352
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()f
full-evening-87657
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
d
damp-lion-88352
10/04/2023, 11:11 AMYes it is different
damp-lion-88352
10/04/2023, 11:12 AMYou can print the value in sensor engine, and you will know how it works.
👍 1
f
full-evening-87657
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 configurationfull-evening-87657
10/05/2023, 9:42 AMor maybe 10 attemps for another bugs
d
damp-lion-88352
10/05/2023, 12:14 PMmaybe it's about config map cc @glamorous-carpet-83516
g
glamorous-carpet-83516
10/05/2023, 5:59 PMI’m writing to the doc, sorry
glamorous-carpet-83516
10/05/2023, 5:59 PMdid you deploy an agent in your cluster?
6 Views