Skip to content

Commit

Permalink
chore: flake8
Browse files Browse the repository at this point in the history
  • Loading branch information
smotornyuk committed Sep 6, 2024
1 parent 2910271 commit bc1de09
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions ckanext/harvest/harvesters/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -406,8 +406,8 @@ def last_error_free_job(cls, harvest_job):
HarvestGatherError.harvest_job_id == HarvestJob.id))
.outerjoin(HarvestObject,
sa.and_(HarvestObject.harvest_job_id == HarvestJob.id,
HarvestObject.current == False, # noqa: E712
HarvestObject.report_status != 'not modified'))
HarvestObject.current == False, # noqa: E712
HarvestObject.report_status != 'not modified'))
.options(contains_eager(HarvestJob.objects))
.order_by(HarvestJob.gather_started.desc()))
# now check them until we find one with no fetch/import errors
Expand Down
2 changes: 1 addition & 1 deletion ckanext/harvest/logic/action/update.py
Original file line number Diff line number Diff line change
Expand Up @@ -680,7 +680,7 @@ def harvest_jobs_run(context, data_dict):
session.query(HarvestObject.id) \
.filter(HarvestObject.harvest_job_id == job['id']) \
.filter(sa.and_((HarvestObject.state != u'COMPLETE'),
(HarvestObject.state != u'ERROR'))) \
(HarvestObject.state != u'ERROR'))) \
.count()

if num_objects_in_progress == 0:
Expand Down

0 comments on commit bc1de09

Please sign in to comment.