From b5e2b5bf01330f0776b54597fba4dd921b714e4f Mon Sep 17 00:00:00 2001 From: Josh Fell Date: Sun, 3 Oct 2021 13:27:02 -0400 Subject: [PATCH] Add max_ingestion_time to DruidOperator docstring --- airflow/providers/apache/druid/operators/druid.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/airflow/providers/apache/druid/operators/druid.py b/airflow/providers/apache/druid/operators/druid.py index 3243806e7ca3a..b7872f17fa39f 100644 --- a/airflow/providers/apache/druid/operators/druid.py +++ b/airflow/providers/apache/druid/operators/druid.py @@ -31,6 +31,8 @@ class DruidOperator(BaseOperator): :param druid_ingest_conn_id: The connection id of the Druid overlord which accepts index jobs :type druid_ingest_conn_id: str + :param max_ingestion_time: The maximum ingestion time before assuming the job failed + :type max_ingestion_time: int """ template_fields = ('json_index_file',)