Merge lp:~camptocamp/openerp-connector-magento/7.0-next-release-related-actions into lp:~openerp-connector-core-editors/openerp-connector-magento/7.0-next-release

[Guewen Baconnier @ Camptocamp]

Implements Related Actions

A related action can be attached to a job. It is shown to the user as a button on the form view of the jobs.
When the button is used, the related action is called and must return an OpenERP "client action".

Related action in this connector:
* Open the form view of the record that is concerned by the job on export jobs
* Open a browser on Magento's admin page in order to view/edit the record on import jobs

Implements Related Actions
==========================

Based on the new connector's feature: https://code.launchpad.net/~camptocamp/openerp-connector/7.0-next-release-related-action

A related action can be attached to a job. It is shown to the user as a button on the form view of the jobs.
When the button is used, the related action is called and must return an OpenERP "client action".

Related action in this connector:
* Open the form view of the record that is concerned by the job on export jobs
* Open a browser on Magento's admin page in order to view/edit the record on import jobs

I would like to include this branch in the upcoming release, please test and give me your feedback!

[lp:~camptocamp/openerp-connector-magento/7.0-next-release-related-actions]

985. By Guewen Baconnier @ Camptocamp on 2014-05-12

test method name duplicated

986. By Guewen Baconnier @ Camptocamp on 2014-05-19

rename unwrap_record to unwrap_binding

[David BEAL (ak) (davidbeal)]

Really, really usefull feature

Nice Guewen

Thank you

=== modified file 'magentoerpconnect/CHANGES.rst'
--- magentoerpconnect/CHANGES.rst	2014-05-06 15:46:57 +0000
+++ magentoerpconnect/CHANGES.rst	2014-05-19 11:42:35 +0000
@@ -16,6 +16,8 @@
 * Fix: calculate correctly the discount ratio on sales order lines (lp:1201590)
 * Possibility to exclude products from stock synchronizations
 * Products disabled on Magento are imported disabled on OpenERP. An additional module allows more options.
+* Related Actions: open the form view on the record concerned by an export job, or open the Magento's admin page
+  on importing jobs
 
 
 2.3.1 (2014-01-23)

=== modified file 'magentoerpconnect/invoice.py'
--- magentoerpconnect/invoice.py	2014-04-29 14:11:59 +0000
+++ magentoerpconnect/invoice.py	2014-05-19 11:42:35 +0000
@@ -23,7 +23,7 @@
 import xmlrpclib
 from openerp.osv import fields, orm
 from openerp.tools.translate import _
-from openerp.addons.connector.queue.job import job
+from openerp.addons.connector.queue.job import job, related_action
 from openerp.addons.connector.unit.synchronizer import ExportSynchronizer
 from openerp.addons.connector.event import on_record_create
 from openerp.addons.connector_ecommerce.event import (on_invoice_paid,
@@ -32,6 +32,7 @@
 from .unit.backend_adapter import GenericAdapter
 from .connector import get_environment
 from .backend import magento
+from .related_action import unwrap_binding
 
 _logger = logging.getLogger(__name__)
 
@@ -84,6 +85,7 @@
     """ Backend Adapter for the Magento Invoice """
     _model_name = 'magento.account.invoice'
     _magento_model = 'sales_order_invoice'
+    _admin_path = 'sales_invoice/view/invoice_id/{id}'
 
     def _call(self, method, arguments):
         try:
@@ -248,6 +250,7 @@
 
 
 @job
+@related_action(action=unwrap_binding)
 def export_invoice_paid(session, model_name, record_id):
     """ Deprecated in 2.1.0.dev0. """
     _logger.warning('Deprecated: the export_invoice_paid() job is deprecated '
@@ -256,6 +259,7 @@
 
 
 @job
+@related_action(action=unwrap_binding)
 def export_invoice(session, model_name, record_id):
     """ Export a validated or paid invoice. """
     invoice = session.browse(model_name, record_id)

=== modified file 'magentoerpconnect/magento_model.py'
--- magentoerpconnect/magento_model.py	2014-05-06 09:33:40 +0000
+++ magentoerpconnect/magento_model.py	2014-05-19 11:42:35 +0000
@@ -86,6 +86,7 @@
             'Location',
             required=True,
             help="Url to magento application"),
+        'admin_location': fields.char('Admin Location'),
         'use_custom_api_path': fields.boolean(
             'Custom Api Path',
             help="The default API path is '/index.php/api/xmlrpc'. "
@@ -517,18 +518,21 @@
 class WebsiteAdapter(GenericAdapter):
     _model_name = 'magento.website'
     _magento_model = 'ol_websites'
+    _admin_path = 'system_store/editWebsite/website_id/{id}'
 
 
 @magento
 class StoreAdapter(GenericAdapter):
     _model_name = 'magento.store'
     _magento_model = 'ol_groups'
+    _admin_path = 'system_store/editGroup/group_id/{id}'
 
 
 @magento
 class StoreviewAdapter(GenericAdapter):
     _model_name = 'magento.storeview'
     _magento_model = 'ol_storeviews'
+    _admin_path = 'system_store/editStore/store_id/{id}'
 
 
 @magento

=== modified file 'magentoerpconnect/magento_model_view.xml'
--- magentoerpconnect/magento_model_view.xml	2014-04-04 08:46:16 +0000
+++ magentoerpconnect/magento_model_view.xml	2014-05-19 11:42:35 +0000
@@ -123,6 +123,7 @@
 
                             <page name="advanced_configuration" string="Advanced Configuration">
                                 <group>
+                                    <field name="admin_location" placeholder="e.g. http://my.magento.com/admin"/>
                                     <field name="default_lang_id" widget="selection"/>
                                     <field name="default_category_id"/>
                                     <field name="sale_prefix" placeholder="mag-" />

=== modified file 'magentoerpconnect/partner.py'
--- magentoerpconnect/partner.py	2014-04-17 08:40:19 +0000
+++ magentoerpconnect/partner.py	2014-05-19 11:42:35 +0000
@@ -206,6 +206,7 @@
 class PartnerAdapter(GenericAdapter):
     _model_name = 'magento.res.partner'
     _magento_model = 'customer'
+    _admin_path = '/{model}/edit/id/{id}'
 
     def _call(self, method, arguments):
         try:

=== modified file 'magentoerpconnect/partner_category.py'
--- magentoerpconnect/partner_category.py	2013-07-26 09:06:53 +0000
+++ magentoerpconnect/partner_category.py	2014-05-19 11:42:35 +0000
@@ -73,6 +73,7 @@
 class PartnerCategoryAdapter(GenericAdapter):
     _model_name = 'magento.res.partner.category'
     _magento_model = 'ol_customer_groups'
+    _admin_path = '/customer_group/edit/id/{id}'
 
     def search(self, filters=None):
         """ Search records according to some criterias

=== modified file 'magentoerpconnect/product.py'
--- magentoerpconnect/product.py	2014-05-06 16:20:16 +0000
+++ magentoerpconnect/product.py	2014-05-19 11:42:35 +0000
@@ -27,7 +27,7 @@
 import sys
 from openerp.osv import orm, fields
 from openerp.tools.translate import _
-from openerp.addons.connector.queue.job import job
+from openerp.addons.connector.queue.job import job, related_action
 from openerp.addons.connector.event import on_record_write
 from openerp.addons.connector.unit.synchronizer import (ImportSynchronizer,
                                                         ExportSynchronizer
@@ -49,6 +49,7 @@
                                        )
 from .connector import get_environment
 from .backend import magento
+from .related_action import unwrap_binding
 
 _logger = logging.getLogger(__name__)
 
@@ -176,6 +177,7 @@
 class ProductProductAdapter(GenericAdapter):
     _model_name = 'magento.product.product'
     _magento_model = 'catalog_product'
+    _admin_path = '/{model}/edit/id/{id}'
 
     def _call(self, method, arguments):
         try:
@@ -557,6 +559,7 @@
 
 
 @job
+@related_action(action=unwrap_binding)
 def export_product_inventory(session, model_name, record_id, fields=None):
     """ Export the inventory configuration and quantity of a product. """
     product = session.browse(model_name, record_id)

=== modified file 'magentoerpconnect/product_category.py'
--- magentoerpconnect/product_category.py	2013-07-26 09:06:53 +0000
+++ magentoerpconnect/product_category.py	2014-05-19 11:42:35 +0000
@@ -87,6 +87,7 @@
 class ProductCategoryAdapter(GenericAdapter):
     _model_name = 'magento.product.category'
     _magento_model = 'catalog_category'
+    _admin_path = '/{model}/index/'
 
     def _call(self, method, arguments):
         try:

=== added file 'magentoerpconnect/related_action.py'
--- magentoerpconnect/related_action.py	1970-01-01 00:00:00 +0000
+++ magentoerpconnect/related_action.py	2014-05-19 11:42:35 +0000
@@ -0,0 +1,65 @@
+# -*- coding: utf-8 -*-
+##############################################################################
+#
+#    Author: Guewen Baconnier
+#    Copyright 2014 Camptocamp SA
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU Affero General Public License as
+#    published by the Free Software Foundation, either version 3 of the
+#    License, or (at your option) any later version.
+#
+#    This program is distributed in the hope that it will be useful,
+#    but WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#    GNU Affero General Public License for more details.
+#
+#    You should have received a copy of the GNU Affero General Public License
+#    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+##############################################################################
+
+"""
+Related Actions for Magento:
+
+Related actions are associated with jobs.
+When called on a job, they will return an action to the client.
+
+"""
+
+import  functools
+from openerp.osv import orm
+from openerp.tools.translate import _
+from openerp.addons.connector import related_action
+from .connector import get_environment
+from .unit.backend_adapter import GenericAdapter
+from .unit.binder import MagentoBinder
+
+unwrap_binding = functools.partial(related_action.unwrap_binding,
+                                   binder_class=MagentoBinder)
+
+
+def link(session, job, backend_id_pos=2, magento_id_pos=3):
+    """ Open a Magento URL on the admin page to view/edit the record
+    related to the job.
+    """
+    binding_model = job.args[0]
+    # shift one to the left because session is not in job.args
+    backend_id = job.args[backend_id_pos - 1]
+    magento_id = job.args[magento_id_pos - 1]
+    env = get_environment(session, binding_model, backend_id)
+    adapter = env.get_connector_unit(GenericAdapter)
+    try:
+        url = adapter.admin_url(magento_id)
+    except ValueError:
+        raise orm.except_orm(
+            _('Error'),
+            _('No admin URL configured on the backend or '
+              'no admin path is defined for this record.'))
+
+    action = {
+        'type': 'ir.actions.act_url',
+        'target': 'new',
+        'url': url,
+    }
+    return action

=== modified file 'magentoerpconnect/sale.py'
--- magentoerpconnect/sale.py	2014-05-06 08:36:26 +0000
+++ magentoerpconnect/sale.py	2014-05-19 11:42:35 +0000
@@ -211,6 +211,7 @@
 class SaleOrderAdapter(GenericAdapter):
     _model_name = 'magento.sale.order'
     _magento_model = 'sales_order'
+    _admin_path = '{model}/view/order_id/{id}'
 
     def _call(self, method, arguments):
         try:

=== modified file 'magentoerpconnect/stock_picking.py'
--- magentoerpconnect/stock_picking.py	2014-01-14 10:38:32 +0000
+++ magentoerpconnect/stock_picking.py	2014-05-19 11:42:35 +0000
@@ -23,7 +23,7 @@
 import xmlrpclib
 from openerp.osv import orm, fields
 from openerp.tools.translate import _
-from openerp.addons.connector.queue.job import job
+from openerp.addons.connector.queue.job import job, related_action
 from openerp.addons.connector.event import on_record_create
 from openerp.addons.connector.exception import NothingToDoJob
 from openerp.addons.connector.unit.synchronizer import ExportSynchronizer
@@ -33,6 +33,7 @@
 from .connector import get_environment
 from .backend import magento
 from .stock_tracking import export_tracking_number
+from .related_action import unwrap_binding
 
 _logger = logging.getLogger(__name__)
 
@@ -99,6 +100,7 @@
 class StockPickingAdapter(GenericAdapter):
     _model_name = 'magento.stock.picking.out'
     _magento_model = 'sales_order_shipment'
+    _admin_path = 'sales_shipment/view/shipment_id/{id}'
 
     def _call(self, method, arguments):
         try:
@@ -248,6 +250,7 @@
 
 
 @job
+@related_action(action=unwrap_binding)
 def export_picking_done(session, model_name, record_id):
     """ Export a complete or partial delivery order. """
     picking = session.browse(model_name, record_id)

=== modified file 'magentoerpconnect/stock_tracking.py'
--- magentoerpconnect/stock_tracking.py	2013-10-12 19:50:31 +0000
+++ magentoerpconnect/stock_tracking.py	2014-05-19 11:42:35 +0000
@@ -21,12 +21,13 @@
 
 import logging
 from openerp.tools.translate import _
-from openerp.addons.connector.queue.job import job
+from openerp.addons.connector.queue.job import job, related_action
 from openerp.addons.connector.exception import FailedJobError, NoExternalId
 from openerp.addons.connector.unit.synchronizer import ExportSynchronizer
 from openerp.addons.connector_ecommerce.event import on_tracking_number_added
 from .connector import get_environment
 from .backend import magento
+from .related_action import unwrap_binding
 
 _logger = logging.getLogger(__name__)
 
@@ -117,6 +118,7 @@
 
 
 @job
+@related_action(action=unwrap_binding)
 def export_tracking_number(session, model_name, record_id):
     """ Export the tracking number of a delivery order. """
     picking = session.browse(model_name, record_id)

=== modified file 'magentoerpconnect/tests/__init__.py'
--- magentoerpconnect/tests/__init__.py	2014-03-19 10:34:00 +0000
+++ magentoerpconnect/tests/__init__.py	2014-05-19 11:42:35 +0000
@@ -23,6 +23,9 @@
 import test_address_book
 import test_export_invoice
 import test_import_product_image
+import test_related_action
+
+
 fast_suite = [
 ]
 
@@ -31,4 +34,5 @@
     test_address_book,
     test_export_invoice,
     test_import_product_image,
+    test_related_action,
 ]

=== added file 'magentoerpconnect/tests/test_related_action.py'
--- magentoerpconnect/tests/test_related_action.py	1970-01-01 00:00:00 +0000
+++ magentoerpconnect/tests/test_related_action.py	2014-05-19 11:42:35 +0000
@@ -0,0 +1,98 @@
+# -*- coding: utf-8 -*-
+import mock
+import unittest2
+
+import openerp
+import openerp.tests.common as common
+from openerp.addons.connector.queue.job import (
+    Job,
+    OpenERPJobStorage,
+    related_action)
+from openerp.addons.connector.session import (
+    ConnectorSession)
+from .common import (mock_api,
+                     mock_urlopen_image)
+from .test_data import magento_base_responses
+from ..unit.import_synchronizer import import_batch, import_record
+from ..unit.export_synchronizer import export_record
+from ..related_action import unwrap_binding, link
+
+
+class test_related_action_storage(common.TransactionCase):
+    """ Test related actions on stored jobs """
+
+    def setUp(self):
+        super(test_related_action_storage, self).setUp()
+        cr, uid = self.cr, self.uid
+        backend_model = self.registry('magento.backend')
+        self.session = ConnectorSession(cr, uid)
+        warehouse_id = self.ref('stock.warehouse0')
+        backend_id = backend_model.create(
+            cr,
+            uid,
+            {'name': 'Test Magento',
+                'version': '1.7',
+                'location': 'http://anyurl',
+                'username': 'username',
+                'warehouse_id': warehouse_id,
+                'password': '42'})
+        self.backend = backend_model.browse(cr, uid, backend_id)
+        # import the base informations
+        with mock_api(magento_base_responses):
+            import_batch(self.session, 'magento.website', backend_id)
+            import_batch(self.session, 'magento.store', backend_id)
+            import_batch(self.session, 'magento.storeview', backend_id)
+        self.MagentoProduct = self.registry('magento.product.product')
+        self.QueueJob = self.registry('queue.job')
+
+    def test_unwrap_binding(self):
+        """ Open a related action opening an unwrapped binding """
+        cr, uid = self.cr, self.uid
+        product_id = self.ref('product.product_product_7')
+        magento_product_id = self.MagentoProduct.create(
+            cr, uid,
+            {'openerp_id': product_id,
+             'backend_id': self.backend.id})
+        stored = self._create_job(export_record, 'magento.product.product',
+                                  magento_product_id)
+        expected = {
+            'name': mock.ANY,
+            'type': 'ir.actions.act_window',
+            'view_type': 'form',
+            'view_mode': 'form',
+            'res_id': product_id,
+            'res_model': 'product.product',
+        }
+        self.assertEquals(stored.open_related_action(), expected)
+
+    def _create_job(self, func, *args):
+        cr, uid = self.cr, self.uid
+        job = Job(func=func, args=args)
+        storage = OpenERPJobStorage(self.session)
+        storage.store(job)
+        stored_ids = self.QueueJob.search(self.cr, self.uid,
+                                          [('uuid', '=', job.uuid)])
+        self.assertEqual(len(stored_ids), 1)
+        return self.QueueJob.browse(cr, uid, stored_ids[0])
+
+    def test_link(self):
+        """ Open a related action opening an url on Magento """
+        self.backend.write({'admin_location': 'http://www.example.com/admin'})
+        self.backend.refresh()
+        stored = self._create_job(import_record, 'magento.product.product',
+                                  self.backend.id, 123456)
+        expected = {
+            'type': 'ir.actions.act_url',
+            'target': 'new',
+            'url': 'http://www.example.com/admin/catalog_product/edit/id/123456',
+        }
+        self.assertEquals(stored.open_related_action(), expected)
+
+    def test_link_no_location(self):
+        """ Open a related action opening an url but admin location is not configured """
+        self.backend.write({'admin_location': False})
+        self.backend.refresh()
+        stored = self._create_job(import_record, 'magento.product.product',
+                                  self.backend.id, 123456)
+        with self.assertRaises(openerp.osv.orm.except_orm):
+            stored.open_related_action()

=== modified file 'magentoerpconnect/unit/backend_adapter.py'
--- magentoerpconnect/unit/backend_adapter.py	2014-05-06 09:33:40 +0000
+++ magentoerpconnect/unit/backend_adapter.py	2014-05-19 11:42:35 +0000
@@ -182,6 +182,7 @@
 
     _model_name = None
     _magento_model = None
+    _admin_path = None
 
     def search(self, filters=None):
         """ Search records according to some criterias
@@ -228,3 +229,18 @@
     def delete(self, id):
         """ Delete a record on the external system """
         return self._call('%s.delete' % self._magento_model, [int(id)])
+
+    def admin_url(self, id):
+        """ Return the URL in the Magento admin for a record """
+        if self._admin_path is None:
+            raise ValueError('No admin path is defined for this record')
+        backend = self.backend_record
+        url = backend.admin_location
+        if not url:
+            raise ValueError('No admin URL configured on the backend.')
+        path = self._admin_path.format(model=self._magento_model,
+                                       id=id)
+        url = url.rstrip('/')
+        path = path.lstrip('/')
+        url = '/'.join((url, path))
+        return url

=== modified file 'magentoerpconnect/unit/binder.py'
--- magentoerpconnect/unit/binder.py	2013-11-21 09:34:17 +0000
+++ magentoerpconnect/unit/binder.py	2014-05-19 11:42:35 +0000
@@ -124,3 +124,36 @@
             {'magento_id': str(external_id),
              'sync_date': now_fmt},
             context=context)
+
+    def unwrap_binding(self, binding_id, browse=False):
+        """ For a binding record, gives the normal record.
+
+        Example: when called with a ``magento.product.product`` id,
+        it will return the corresponding ``product.product`` id.
+
+        :param browse: when True, returns a browse_record instance
+                       rather than an ID
+        """
+        binding = self.session.read(self.model._name, binding_id,
+                                    ['openerp_id'])
+        openerp_id = binding['openerp_id'][0]
+        if browse:
+            return self.session.browse(self.unwrap_model(),
+                                       openerp_id)
+        return openerp_id
+
+    def unwrap_model(self):
+        """ For a binding model, gives the name of the normal model.
+
+        Example: when called on a binder for ``magento.product.product``,
+        it will return ``product.product``.
+
+        This binder assumes that the normal model lays in ``openerp_id`` since
+        this is the field we use in the ``_inherits`` bindings.
+        """
+        try:
+            column = self.model._columns['openerp_id']
+        except KeyError:
+            raise ValueError('Cannot unwrap model %s, because it has '
+                             'no openerp_id field' % self.model._name)
+        return column._obj

=== modified file 'magentoerpconnect/unit/delete_synchronizer.py'
--- magentoerpconnect/unit/delete_synchronizer.py	2013-03-19 16:53:26 +0000
+++ magentoerpconnect/unit/delete_synchronizer.py	2014-05-19 11:42:35 +0000
@@ -20,9 +20,10 @@
 ##############################################################################
 
 from openerp.tools.translate import _
-from openerp.addons.connector.queue.job import job
+from openerp.addons.connector.queue.job import job, related_action
 from openerp.addons.connector.unit.synchronizer import DeleteSynchronizer
 from ..connector import get_environment
+from ..related_action import link
 
 
 class MagentoDeleteSynchronizer(DeleteSynchronizer):
@@ -38,6 +39,7 @@
 
 
 @job
+@related_action(action=link)
 def export_delete_record(session, model_name, backend_id, magento_id):
     """ Delete a record on Magento """
     env = get_environment(session, model_name, backend_id)

=== modified file 'magentoerpconnect/unit/export_synchronizer.py'
--- magentoerpconnect/unit/export_synchronizer.py	2014-04-02 14:32:31 +0000
+++ magentoerpconnect/unit/export_synchronizer.py	2014-05-19 11:42:35 +0000
@@ -23,11 +23,12 @@
 from datetime import datetime
 from openerp.tools.translate import _
 from openerp.tools import DEFAULT_SERVER_DATETIME_FORMAT
-from openerp.addons.connector.queue.job import job
+from openerp.addons.connector.queue.job import job, related_action
 from openerp.addons.connector.unit.synchronizer import ExportSynchronizer
 from openerp.addons.connector.exception import IDMissingInBackend
 from .import_synchronizer import import_record
 from ..connector import get_environment
+from ..related_action import unwrap_binding
 
 _logger = logging.getLogger(__name__)
 
@@ -209,6 +210,7 @@
 
 
 @job
+@related_action(action=unwrap_binding)
 def export_record(session, model_name, binding_id, fields=None):
     """ Export a record on Magento """
     record = session.browse(model_name, binding_id)

=== modified file 'magentoerpconnect/unit/import_synchronizer.py'
--- magentoerpconnect/unit/import_synchronizer.py	2014-03-19 07:31:29 +0000
+++ magentoerpconnect/unit/import_synchronizer.py	2014-05-19 11:42:35 +0000
@@ -23,12 +23,13 @@
 from datetime import datetime
 from openerp.tools.translate import _
 from openerp.tools import DEFAULT_SERVER_DATETIME_FORMAT
-from openerp.addons.connector.queue.job import job
+from openerp.addons.connector.queue.job import job, related_action
 from openerp.addons.connector.connector import ConnectorUnit
 from openerp.addons.connector.unit.synchronizer import ImportSynchronizer
 from openerp.addons.connector.exception import IDMissingInBackend
 from ..backend import magento
 from ..connector import get_environment, add_checkpoint
+from ..related_action import link
 
 _logger = logging.getLogger(__name__)
 
@@ -359,6 +360,7 @@
 
 
 @job
+@related_action(action=link)
 def import_record(session, model_name, backend_id, magento_id, force=False):
     """ Import a record from Magento """
     env = get_environment(session, model_name, backend_id)

=== modified file 'magentoerpconnect_pricing/product.py'
--- magentoerpconnect_pricing/product.py	2013-07-01 11:20:54 +0000
+++ magentoerpconnect_pricing/product.py	2014-05-19 11:42:35 +0000
@@ -21,7 +21,7 @@
 
 
 from openerp.tools.translate import _
-from openerp.addons.connector.queue.job import job
+from openerp.addons.connector.queue.job import job, related_action
 from openerp.addons.connector.exception import FailedJobError
 from openerp.addons.connector.unit.mapper import (mapping,
                                                   only_create
@@ -32,8 +32,12 @@
 from openerp.addons.magentoerpconnect.backend import magento
 from openerp.addons.magentoerpconnect import product
 from openerp.addons.magentoerpconnect.connector import get_environment
-
-
+from openerp.addons.magentoerpconnect.related_action import (
+    unwrap_binding,
+)
+
+
+# TODO: replace a price mapper only, not the full mapper
 @magento(replacing=product.ProductImportMapper)
 class ProductImportMapper(product.ProductImportMapper):
     _model_name = 'magento.product.product'
@@ -142,6 +146,7 @@
 
 
 @job
+@related_action(action=unwrap_binding)
 def export_product_price(session, model_name, record_id, website_id=None):
     """ Export the price of a product. """
     product_bind = session.browse(model_name, record_id)