You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2021/09/20 22:44:30 UTC
[airflow] branch main updated: Added example JSON for airflow pools
import (#18376)
This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new ef0ff3f Added example JSON for airflow pools import (#18376)
ef0ff3f is described below
commit ef0ff3f02b366037be1f8c9a0399113a714e1941
Author: Bas Harenslak <Ba...@users.noreply.github.com>
AuthorDate: Tue Sep 21 00:44:07 2021 +0200
Added example JSON for airflow pools import (#18376)
Co-authored-by: Bas Harenslak <ba...@astronomer.io>
---
airflow/cli/cli_parser.py | 17 ++++++++++++++++-
1 file changed, 16 insertions(+), 1 deletion(-)
diff --git a/airflow/cli/cli_parser.py b/airflow/cli/cli_parser.py
index 15390be..7093116 100644
--- a/airflow/cli/cli_parser.py
+++ b/airflow/cli/cli_parser.py
@@ -357,7 +357,22 @@ ARG_EXEC_DATE = Arg(("-e", "--exec-date"), help="The execution date of the DAG",
ARG_POOL_NAME = Arg(("pool",), metavar='NAME', help="Pool name")
ARG_POOL_SLOTS = Arg(("slots",), type=int, help="Pool slots")
ARG_POOL_DESCRIPTION = Arg(("description",), help="Pool description")
-ARG_POOL_IMPORT = Arg(("file",), metavar="FILEPATH", help="Import pools from JSON file")
+ARG_POOL_IMPORT = Arg(
+ ("file",),
+ metavar="FILEPATH",
+ help="Import pools from JSON file. Example format::\n"
+ + textwrap.indent(
+ textwrap.dedent(
+ '''
+ {
+ "pool_1": {"slots": 5, "description": ""},
+ "pool_2": {"slots": 10, "description": "test"}
+ }'''
+ ),
+ " " * 4,
+ ),
+)
+
ARG_POOL_EXPORT = Arg(("file",), metavar="FILEPATH", help="Export all pools to JSON file")
# variables