|
115 | 115 | h5_stream_prov_op = dpf.operators.metadata.streams_provider()
|
116 | 116 | h5_stream_prov_op.inputs.data_sources.connect(h5_all_times_ds)
|
117 | 117 | res_deser_all_times_list = []
|
118 |
| -h5_read_op = dpf.operators.serialization.hdf5dpf_custom_read() |
119 |
| -h5_read_op.inputs.streams.connect(h5_stream_prov_op.outputs) |
| 118 | +h5_read_op = dpf.operators.result.custom() |
| 119 | +h5_read_op.inputs.streams_container.connect(h5_stream_prov_op.outputs) |
120 | 120 | h5_read_op.inputs.time_scoping.connect(dpf.Scoping(ids=list(range(1, 54)), location="time"))
|
121 | 121 | for i, res_name in enumerate(result_names_on_all_time_steps):
|
122 | 122 | h5_read_op.inputs.result_name.connect(res_name)
|
123 |
| - res_deser = h5_read_op.outputs.field_or_fields_container_as_fields_container() |
| 123 | + res_deser = h5_read_op.outputs.fields_container() |
124 | 124 | res_deser_all_times_list.append(res_deser)
|
125 | 125 |
|
126 | 126 | ###############################################################################
|
|
134 | 134 | h5_stream_prov_op_2 = dpf.operators.metadata.streams_provider()
|
135 | 135 | h5_stream_prov_op_2.inputs.data_sources.connect(h5_set_per_set_ds)
|
136 | 136 | res_deser_set_per_set_list = []
|
137 |
| -h5_read_op_2 = dpf.operators.serialization.hdf5dpf_custom_read() |
138 |
| -h5_read_op_2.inputs.streams.connect(h5_stream_prov_op_2.outputs) |
| 137 | +h5_read_op_2 = dpf.operators.result.custom() |
| 138 | +h5_read_op_2.inputs.streams_container.connect(h5_stream_prov_op_2.outputs) |
139 | 139 | for i, res_name in enumerate(result_names_time_per_time):
|
140 | 140 | h5_read_op_2.inputs.result_name.connect(res_name)
|
141 |
| - res_deser = h5_read_op_2.outputs.field_or_fields_container_as_fields_container() |
| 141 | + res_deser = h5_read_op_2.outputs.fields_container() |
142 | 142 | res_deser_set_per_set_list.append(res_deser)
|
143 | 143 |
|
144 | 144 | ###############################################################################
|
|
0 commit comments