fromairflow.operators.bashimportBashOperatorfromairflow.sensors.filesystemimportFileSensorfromflytekitimporttask,workflow@task()deft1():print("success")# Use the Airflow FileSensor to wait for a file to appear before running the task.@workflowdeffile_sensor():sensor=FileSensor(task_id="id",filepath="/tmp/1234")sensor>>t1()# Use the Airflow BashOperator to run a bash command.@workflowdefbash_sensor():op=BashOperator(task_id="airflow_bash_operator",bash_command="echo hello")op>>t1()