Skip to content

Apply latest options of 'backfill' command #69

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Apply latest options of 'backfill' command #69

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 9 additions & 3 deletions plugins/rest_api_plugin.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -298,12 +298,18 @@ def get_config_boolean_value(section, key, default_value):
{"name": "mark_success", "description": "Mark jobs as succeeded without running them", "form_input_type": "checkbox", "required": False},
{"name": "local", "description": "Run the task using the LocalExecutor", "form_input_type": "checkbox", "required": False},
{"name": "donot_pickle", "description": "Do not attempt to pickle the DAG object to send over to the workers, just tell the workers to run their version of the code.", "form_input_type": "checkbox", "required": False},
{"name": "include_adhoc", "description": "Include dags with the adhoc argument.", "form_input_type": "checkbox", "required": False},
{"name": "ignore_dependencies", "description": "Ignore task-specific dependencies, e.g. upstream, depends_on_past, and retry delay dependencies", "form_input_type": "checkbox", "required": False},
{"name": "ignore_first_depends_on_past", "description": "Ignores depends_on_past dependencies for the first set of tasks only (subsequent executions in the backfill DO respect depends_on_past).", "form_input_type": "checkbox", "required": False},
{"name": "subdir", "description": "File location or directory from which to look for the dag", "form_input_type": "text", "required": False},
{"name": "pool", "description": "Resource pool to use", "form_input_type": "text", "required": False},
{"name": "dry_run", "description": "Perform a dry run", "form_input_type": "checkbox", "required": False}
{"name": "delay_on_limit", "description": "Amount of time in seconds to wait when the limit on maximum active dag runs (max_active_runs) has been reached before trying to execute a dag run again.", "form_input_type": "text", "required": False},
{"name": "dry_run", "description": "Perform a dry run", "form_input_type": "checkbox", "required": False},
{"name": "reset_dagruns", "description": "If set, the backfill will delete existing backfill-related DAG runs and start anew with fresh, running DAG runs", "form_input_type": "checkbox", "required": False},
{"name": "rerun_failed_tasks", "description": "If set, the backfill will auto-rerun all the failed tasks for the backfill date range instead of throwing exceptions", "form_input_type": "checkbox", "required": False},
{"name": "run_backwards", "description": "If set, the backfill will run tasks from the most recent day first. if there are tasks that depend_on_past this option will throw an exception", "form_input_type": "checkbox", "required": False}
],
"fixed_arguments": [
{"name": "yes", "description": "Do not prompt to confirm reset", "fixed_value": ""}
]
},
{
Expand Down Expand Up @@ -993,4 +999,4 @@ class REST_API_Plugin(AirflowPlugin):
hooks = []
executors = []
admin_views = [rest_api_view]
menu_links = []
menu_links = []