Merge branch 'source-is-a-dict'
This commit is contained in:
commit
18f8a92084
|
@ -105,9 +105,9 @@ def harvest_job_create_all(context,data_dict):
|
||||||
jobs = []
|
jobs = []
|
||||||
# Create a new job for each, if there isn't already one
|
# Create a new job for each, if there isn't already one
|
||||||
for source in sources:
|
for source in sources:
|
||||||
exists = _check_for_existing_jobs(context, source.id)
|
exists = _check_for_existing_jobs(context, source['id'])
|
||||||
if exists:
|
if exists:
|
||||||
log.info('Skipping source %s as it already has a pending job',source.id)
|
log.info('Skipping source %s as it already has a pending job', source['id'])
|
||||||
continue
|
continue
|
||||||
|
|
||||||
job = harvest_job_create(context,{'source_id':source['id']})
|
job = harvest_job_create(context,{'source_id':source['id']})
|
||||||
|
|
Loading…
Reference in New Issue