Created overridable method that makes accessor from np.ndarray

model_server/base/pipelines/shared.py

@@ -156,13 +156,17 @@ class PipelineTrace(OrderedDict):
             if self.enforce_accessors:
                 raise NoAccessorsFoundError(f'Pipeline trace expects data accessor type')
             else:
-                acc = InMemoryDataAccessor(value)
+                acc = self.make_accessor(value)
         if not self.allow_overwrite and key in self.keys():
             raise KeyAlreadyExists(f'key {key} already exists in pipeline trace')
         self.timer.__setitem__(key, self.tfunc() - self.last_time)
         self.last_time = self.tfunc()
         return super().__setitem__(key, acc)
 
+    @staticmethod
+    def make_accessor(data):
+        return InMemoryDataAccessor(data)
+
     def append(self, tr, skip_first=True):
         new_tr = self.copy()
         for k, v in tr.items():