Skip to content

Commit

Permalink
Fix typo in timed_out (#10459)
Browse files Browse the repository at this point in the history
`timeouted` -> `timed_out`
  • Loading branch information
kaxil committed Aug 22, 2020
1 parent 27339a5 commit 515cc72
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 5 deletions.
6 changes: 3 additions & 3 deletions airflow/jobs/scheduler_job.py
Original file line number Diff line number Diff line change
Expand Up @@ -566,7 +566,7 @@ def create_dag_run(
# return if already reached maximum active runs and no timeout setting
if len(active_runs) >= dag.max_active_runs and not dag.dagrun_timeout:
return None
timeouted_runs = 0
timed_out_runs = 0
for dr in active_runs:
if (
dr.start_date and dag.dagrun_timeout and
Expand All @@ -576,9 +576,9 @@ def create_dag_run(
dr.end_date = timezone.utcnow()
dag.handle_callback(dr, success=False, reason='dagrun_timeout',
session=session)
timeouted_runs += 1
timed_out_runs += 1
session.commit()
if len(active_runs) - timeouted_runs >= dag.max_active_runs:
if len(active_runs) - timed_out_runs >= dag.max_active_runs:
return None

# this query should be replaced by find dagrun
Expand Down
2 changes: 1 addition & 1 deletion airflow/providers/google/cloud/hooks/datafusion.py
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,7 @@ def wait_for_pipeline_state(
):
"""
Polls pipeline state and raises an exception if the state is one of
`failure_states` or the operation timeouted.
`failure_states` or the operation timed_out.
"""
failure_states = failure_states or FAILURE_STATES
success_states = success_states or SUCCESS_STATES
Expand Down
1 change: 0 additions & 1 deletion docs/spelling_wordlist.txt
Original file line number Diff line number Diff line change
Expand Up @@ -1219,7 +1219,6 @@ tez
theService
timedelta
timeframe
timeouted
timezones
tis
tls
Expand Down

0 comments on commit 515cc72

Please sign in to comment.