it will retry if needed

class FileSensor(BaseSensor): # type: ignore

    def __init__(self, name: str | None = None, timeout: int = 60, **kwargs: Any) -> None:
        super().__init__(name=name, timeout=timeout, **kwargs) # type: ignore
        self.initial_poke = datetime.now()

    async def poke(self, path: str) -> bool:
        diff_in_seconds = (datetime.now() - self.initial_poke).total_seconds()
        if diff_in_seconds > self.timeout:
            raise FlyteException(f"Timed out after {diff_in_seconds}")

from flytekit import task, workflow
from flytekit.core.task import TaskMetadata
from flytekit.sensor.file_sensor import FileSensor

sensor = FileSensor(name="test_file_sensor", metadata=TaskMetadata(timeout=5))

@task()
def t1():
    print("SUCCEEDED")


@workflow()
def wf():
    sensor(path="./hello") >> t1()