Optimization: no unnecessary data unpacking/re-packing

beat/core/execution.py

@@ -291,7 +291,7 @@ class Executor(object):
         db = self.databases[details['database']]
 
         dataformat_name = db.set(details['protocol'], details['set'])['outputs'][details['output']]
-        input = inputs.RemoteInput(name, db.dataformats[dataformat_name], self.db_socket)
+        input = inputs.RemoteInput(name, db.dataformats[dataformat_name], self.db_socket, unpack=False)
 
         # Synchronization bits
         group = self.input_list.group(details['channel'])
@@ -315,11 +315,13 @@ class Executor(object):
                     prefix=self.prefix,
                     force_start_index=start_index,
                     force_end_index=end_index,
+                    unpack=False,
                   )
         else:
           status = data_source.setup(
                     filename=os.path.join(self.cache, details['path'] + '.data'),
                     prefix=self.prefix,
+                    unpack=False,
                   )
 
         if not status: