Add customization hook for datasync consumer when fetching local object
This commit is contained in:
parent
5416fdfdbe
commit
1ffaacb3d2
|
@ -182,7 +182,7 @@ class NewDataSyncImportConsumer(DataSyncConsumer):
|
||||||
if host_data is None:
|
if host_data is None:
|
||||||
return
|
return
|
||||||
key = importer.get_key(host_data)
|
key = importer.get_key(host_data)
|
||||||
local_object = importer.get_local_object(key)
|
local_object = self.get_local_object(importer, key, host_data)
|
||||||
if local_object:
|
if local_object:
|
||||||
if importer.allow_update:
|
if importer.allow_update:
|
||||||
local_data = importer.normalize_local_object(local_object)
|
local_data = importer.normalize_local_object(local_object)
|
||||||
|
@ -216,6 +216,12 @@ class NewDataSyncImportConsumer(DataSyncConsumer):
|
||||||
"""
|
"""
|
||||||
raise NotImplementedError
|
raise NotImplementedError
|
||||||
|
|
||||||
|
def get_local_object(self, importer, key, host_data):
|
||||||
|
"""
|
||||||
|
Fetch the "local" (destination) object for the given key.
|
||||||
|
"""
|
||||||
|
return importer.get_local_object(key)
|
||||||
|
|
||||||
|
|
||||||
class NullTestConsumer(DataSyncConsumer):
|
class NullTestConsumer(DataSyncConsumer):
|
||||||
"""
|
"""
|
||||||
|
|
Loading…
Reference in a new issue