task concurrency

jmnavarrol · Jul 30, 2021 · caf3c25 · caf3c25
1 parent cc1e0d7
commit caf3c25
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/airflow.md b/airflow.md
@@ -653,6 +653,11 @@ with DAG(DAG_NAME,
                    # retry_delay=timedelta(seconds=30),
                    doc_md="""
 ```
+```python
+# task concurrency
+t1 = BaseOperator(pool='my_custom_pool', task_concurrency=12)
+```
+	
 
 * simple DAG
 ```python