Add sensor to operators (#414)
Sensors are not part of the plugin API in airflow 1.9
This commit is contained in:
Родитель
0fbc38df9f
Коммит
bf1e5f7cb7
|
@ -1,6 +1,6 @@
|
|||
from airflow import DAG
|
||||
from datetime import datetime, timedelta
|
||||
from airflow.sensors.s3fs_check_success import S3FSCheckSuccessSensor
|
||||
from airflow.operators.s3fs_check_success import S3FSCheckSuccessSensor
|
||||
from airflow.operators.dataset_status import DatasetStatusOperator
|
||||
|
||||
default_args = {
|
||||
|
|
|
@ -58,5 +58,4 @@ class S3FSCheckSuccessSensor(BaseSensorOperator):
|
|||
|
||||
class S3FSCheckSuccessPlugin(AirflowPlugin):
|
||||
name = "s3fs_check_success"
|
||||
operators = [S3FSCheckSuccessOperator]
|
||||
sensors = [S3FSCheckSuccessSensor]
|
||||
operators = [S3FSCheckSuccessOperator, S3FSCheckSuccessSensor]
|
||||
|
|
Загрузка…
Ссылка в новой задаче