You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ka...@apache.org on 2020/06/22 18:30:51 UTC
[airflow] 05/05: Fix docs on creating CustomOperator (#8678)
This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a commit to branch v1-10-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 92a1040ce152118997fe75231acc4069e3668b48
Author: Jonny Fuller <mr...@gmail.com>
AuthorDate: Sat May 9 20:33:45 2020 -0400
Fix docs on creating CustomOperator (#8678)
(cherry picked from commit 5e1c33a1baf0725eeb695a96b29ddd9585df51e4)
---
docs/howto/custom-operator.rst | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/docs/howto/custom-operator.rst b/docs/howto/custom-operator.rst
index 7713468..a9733d2 100644
--- a/docs/howto/custom-operator.rst
+++ b/docs/howto/custom-operator.rst
@@ -148,7 +148,7 @@ the operator.
self.name = name
def execute(self, context):
- message = "Hello from {}".format(name)
+ message = "Hello from {}".format(self.name)
print(message)
return message
@@ -157,9 +157,9 @@ You can use the template as follows:
.. code:: python
with dag:
- hello_task = HelloOperator(task_id='task_id_1', dag=dag, name='{{ task_id }}')
+ hello_task = HelloOperator(task_id='task_id_1', dag=dag, name='{{ task_instance.task_id }}')
-In this example, Jinja looks for the ``name`` parameter and substitutes ``{{ task_id }}`` with
+In this example, Jinja looks for the ``name`` parameter and substitutes ``{{ task_instance.task_id }}`` with
``task_id_1``.