From daa9a385ff39424bce5e159174df438cd6c7c536 Mon Sep 17 00:00:00 2001 From: amercader Date: Thu, 24 Jan 2013 17:36:58 +0000 Subject: [PATCH] Update job keys changed on 9ba6e8f --- ckanext/harvest/commands/harvester.py | 2 +- ckanext/harvest/logic/action/update.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/ckanext/harvest/commands/harvester.py b/ckanext/harvest/commands/harvester.py index 41d5a8d..1088e8d 100644 --- a/ckanext/harvest/commands/harvester.py +++ b/ckanext/harvest/commands/harvester.py @@ -318,7 +318,7 @@ class Harvester(CkanCommand): def print_harvest_job(self, job): print ' Job id: %s' % job['id'] print ' status: %s' % job['status'] - print ' source: %s' % job['source'] + print ' source: %s' % job['source_id'] print ' objects: %s' % len(job['objects']) print 'gather_errors: %s' % len(job['gather_errors']) diff --git a/ckanext/harvest/logic/action/update.py b/ckanext/harvest/logic/action/update.py index c2690a3..b478abe 100644 --- a/ckanext/harvest/logic/action/update.py +++ b/ckanext/harvest/logic/action/update.py @@ -236,7 +236,7 @@ def harvest_jobs_run(context,data_dict): sent_jobs = [] for job in jobs: context['detailed'] = False - source = harvest_source_show(context,{'id':job['source']}) + source = harvest_source_show(context,{'id':job['source_id']}) if source['active']: job_obj = HarvestJob.get(job['id']) job_obj.status = job['status'] = u'Running'