Commit 19d6bd1f authored by Pierre Paleo's avatar Pierre Paleo
Browse files

datadump (write) OK.

Has to use a "self.data" alias, since "self.radios" will be GPU array
for cuda/opencl backend
parent c469b00d
Pipeline #78578 passed with stage
in 8 minutes and 43 seconds
......@@ -144,4 +144,4 @@ class DataDumpManager:
if len(self.data_dump) > 0:
for step_name, writer_configurator in self.data_dump.items():
res += "\n- Dump %s to %s" % (step_name, writer_configurator.fname)
return res
\ No newline at end of file
return res
......@@ -299,6 +299,7 @@ class NewPipeline:
)
# Importantly:
self.radios = self.chunk_reader.data
self.data = self.chunk_reader.data # alias. This one should always be a "CPU array" (see data dumps)
def _update_reader_configuration(self):
......
......@@ -38,7 +38,7 @@ def pipeline_step(step_attr, step_desc):
for callback in callbacks:
callback(self)
if self.datadump_manager is not None and step_name in self.datadump_manager.data_dump:
self._dump_data_to_file(step_name)
self.datadump_manager.dump_data_to_file(step_name, self.data)
return res
return wrapper
return decorator
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment