Skip to content

Commit

Permalink
Update TaskFlow tutorial doc to show how to pass "operator-level" arg…
Browse files Browse the repository at this point in the history
…s. (#21446)

* Remove invalid arg from snippet in TaskFlow tutorial doc

* Add `retries` to a different code snippet
  • Loading branch information
josh-fell authored Feb 25, 2022
1 parent eafbcb3 commit 5b41e2d
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions docs/apache-airflow/tutorial_taskflow_api.rst
Original file line number Diff line number Diff line change
Expand Up @@ -301,7 +301,7 @@ to a TaskFlow function which parses the response as JSON.
)
@task(max_retries=2)
@task
def parse_results(api_results):
return json.loads(api_results)
Expand All @@ -312,7 +312,7 @@ The reverse can also be done: passing the output of a TaskFlow function as an in

.. code-block:: python
@task
@task(retries=3)
def create_queue():
"""This is a Python function that creates an SQS queue"""
hook = SqsHook()
Expand Down

0 comments on commit 5b41e2d

Please sign in to comment.