Skip to content

Commit

Permalink
fixup! PR #607 attempt to fix failing test on Python 3.7
Browse files Browse the repository at this point in the history
  • Loading branch information
soxofaan committed Sep 12, 2024
1 parent 5332cf5 commit c8ccfae
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions tests/extra/test_job_management.py
Original file line number Diff line number Diff line change
Expand Up @@ -153,7 +153,7 @@ def mock_job_status(job_id, queued=1, running=2):
output_file = tmp_path / "jobs.csv"

def start_job(row, connection, **kwargs):
year = row["year"]
year = int(row["year"])
return BatchJob(job_id=f"job-{year}", connection=connection)

manager.run_jobs(df=df, start_job=start_job, output_file=output_file)
Expand Down Expand Up @@ -407,7 +407,7 @@ def test_is_resilient_to_backend_failures(self, tmp_path, http_error_status, sle
)

def start_job(row, connection_provider, connection, **kwargs):
year = row["year"]
year = int(row["year"])
return BatchJob(job_id=f"job-{year}", connection=connection)

output_file = tmp_path / "jobs.csv"
Expand Down Expand Up @@ -476,7 +476,7 @@ def test_resilient_backend_reports_error_when_max_retries_exceeded(self, tmp_pat
)

def start_job(row, connection_provider, connection, **kwargs):
year = row["year"]
year = int(row["year"])
return BatchJob(job_id=f"job-{year}", connection=connection)

output_file = tmp_path / "jobs.csv"
Expand Down

0 comments on commit c8ccfae

Please sign in to comment.