Skip to content

Commit 30f73fc

Browse files
author
Zakaria Makrelouf
committed
[REF]connector_importer: use root.import channel for import jobs
1 parent 15866b4 commit 30f73fc

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

connector_importer/models/record.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ def debug_mode(self):
8383
os.environ.get('IMPORTER_DEBUG_MODE')
8484

8585
@api.multi
86-
@job
86+
@job(default_channel='root.import')
8787
def import_record(self, component_name, model_name):
8888
"""This job will import a record."""
8989
with self.backend_id.work_on(self._name) as work:

connector_importer/models/recordset.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22
# Copyright 2018 Camptocamp SA
33
# License AGPL-3.0 or later (http://www.gnu.org/licenses/agpl.html).
44

5-
import json
65
import base64
76
import os
87
from collections import OrderedDict
@@ -240,7 +239,7 @@ def available_models(self):
240239
return self.import_type_id.available_models()
241240

242241
@api.multi
243-
@job
242+
@job(default_channel='root.import')
244243
def import_recordset(self):
245244
"""This job will import a recordset."""
246245
with self.backend_id.work_on(self._name) as work:

connector_importer/models/reporter.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@
77
import csv
88
import io
99
import time
10+
import base64
1011

1112

1213
class ReporterMixin(models.AbstractModel):

0 commit comments

Comments
 (0)