XD-DENG commented on a change in pull request #4234: [AIRFLOW-2761] Parallelize
enqueue in celery executor
URL: https://github.com/apache/incubator-airflow/pull/4234#discussion_r236628644
##########
File path: airflow/utils/dag_processing.py
##########
@@ -175,6 +190,48 @@ def try_number(self):
def state(self):
return self._state
+ @property
+ def pool(self):
+ return self._pool
+
+ @property
+ def priority_weight(self):
+ return self._priority_weight
+
+ @property
+ def queue(self):
+ return self._queue
+
+ @property
+ def key(self):
+ return self._key
+
+ @property
+ def executor_config(self):
+ return self._executor_config
+
+ @provide_session
+ def construct_task_instance(self, session=None, lock_for_update=False):
+ """
+ Construct a TaskInstance from the database based on the primary key
+ :param session: DB session.
Review comment:
Minor: One empty line is expected before this line to render Sphinx properly
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
