|
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