diff --git a/marketorestpython/client.py b/marketorestpython/client.py index d6a3f74..a2db2ea 100644 --- a/marketorestpython/client.py +++ b/marketorestpython/client.py @@ -5120,6 +5120,17 @@ def _create_bulk_export_job(self, entity, fields, filters, format='CSV', columnH raise MarketoException(result['errors'][0]) return result['result'] + def _get_export_jobs_status(self, entity, job_id): + self.authenticate() + args = { + 'access_token': self.token + } + result = self._api_call( + 'get', self.host + '/bulk/v1/{}/export/{}/status.json'.format(entity, job_id), args) + if not result['success']: + raise MarketoException(result['errors'][0]) + return result['result'] + def _export_job_state_machine(self, entity, state, job_id): assert entity is not None, 'Invalid argument: required fields is none.' assert entity is not None, 'Invalid argument: required fields is none.' @@ -5145,10 +5156,10 @@ def get_activities_export_job_file(self, *args, **kargs): return self._export_job_state_machine('activities', 'file', *args, **kargs) def get_leads_export_job_status(self, *args, **kargs): - return self._export_job_state_machine('leads', 'status', *args, **kargs) + return self._get_export_jobs_status('leads', *args, **kargs) def get_activities_export_job_status(self, *args, **kargs): - return self._export_job_state_machine('activities', 'status', *args, **kargs) + return self._get_export_jobs_status('activities', *args, **kargs) def cancel_leads_export_job(self, *args, **kargs): return self._export_job_state_machine('leads', 'cancel', *args, **kargs) diff --git a/setup.py b/setup.py index a421da3..3ab12d7 100644 --- a/setup.py +++ b/setup.py @@ -24,7 +24,7 @@ setup( name='marketorestpython', - version= '0.3.14', + version= '0.3.15', url='https://github.com/jepcastelein/marketo-rest-python', author='Jep Castelein', author_email='jep@castelein.net',