is there a way to achieve the async execution of `...
# ask-the-community
a
is there a way to achieve the async execution of
launch_other_task
?
b
Have you seen the FileSensor? Would this solve your problem? https://docs.flyte.org/en/latest/flytesnacks/examples/sensor/file_sensor_example.html
a
maybe but not in an ideal way. I am actually using
tf.train.checkpoint_iterator
which is a tensorflow function to poll for new checkpoints
so the logic of detecting a checkpoint is handled there
s
you could define a sensor to wait for the file to become available, similar to the file sensor: https://github.com/flyteorg/flytekit/blob/master/flytekit/sensor/file_sensor.py
a
problem is I dont know what the file is called
s
how are you polling?
a
atm using tf.train.checkpoint_iterator
which does the checking internally
and polling
s
you could define a new sensor to handle this. have you tried triggering a task from within your dynamic workflow?
a
yes Im trying that now