有没有人对FileSensor有任何想法?我在研究本地目录中的传感文件时遇到了它.代码如下:
task= FileSensor(
task_id="senseFile"
filepath="etc/hosts",
fs_conn_id='fs_local',
_hook=self.hook,
dag=self.dag,)
Run Code Online (Sandbox Code Playgroud)
我还将我的conn_id和conn类型设置为File(path)并给出{'path':'mypath'}但是即使我设置了一个非现有路径,或者如果文件不在指定路径中,则任务完成而dag是成功的.FileSensor似乎根本无法感知文件.
airflow ×1