Skip to content

Commit

Permalink
Remove BackfillJobRunner class (apache#42943)
Browse files Browse the repository at this point in the history
  • Loading branch information
dstandish authored and pavansharma36 committed Oct 14, 2024
1 parent 81ebdf8 commit 7aa844d
Show file tree
Hide file tree
Showing 15 changed files with 29 additions and 3,287 deletions.
2 changes: 1 addition & 1 deletion airflow/cli/cli_config.py
Original file line number Diff line number Diff line change
Expand Up @@ -924,7 +924,7 @@ def string_lower_type(val):
# jobs check
ARG_JOB_TYPE_FILTER = Arg(
("--job-type",),
choices=("BackfillJob", "LocalTaskJob", "SchedulerJob", "TriggererJob", "DagProcessorJob"),
choices=("LocalTaskJob", "SchedulerJob", "TriggererJob", "DagProcessorJob"),
action="store",
help="The type of job(s) that will be checked.",
)
Expand Down
25 changes: 0 additions & 25 deletions airflow/exceptions.py
Original file line number Diff line number Diff line change
Expand Up @@ -327,31 +327,6 @@ class PoolNotFound(AirflowNotFoundException):
"""Raise when a Pool is not available in the system."""


class NoAvailablePoolSlot(AirflowException):
"""Raise when there is not enough slots in pool."""


class DagConcurrencyLimitReached(AirflowException):
"""Raise when DAG max_active_tasks limit is reached."""


class TaskConcurrencyLimitReached(AirflowException):
"""Raise when task max_active_tasks limit is reached."""


class BackfillUnfinished(AirflowException):
"""
Raises when not all tasks succeed in backfill.
:param message: The human-readable description of the exception
:param ti_status: The information about all task statuses
"""

def __init__(self, message, ti_status):
super().__init__(message)
self.ti_status = ti_status


class FileSyntaxError(NamedTuple):
"""Information about a single error in a file."""

Expand Down
Loading

0 comments on commit 7aa844d

Please sign in to comment.