| 281 | |
| 282 | |
| 283 | class LoadDataStep(BaseStep): |
| 284 | NAME = 'load-data' |
| 285 | |
| 286 | def run_step(self, step_definition, parameters): |
| 287 | var_resolver = VariableResolver() |
| 288 | value = var_resolver.resolve_variables( |
| 289 | parameters, |
| 290 | step_definition['value'], |
| 291 | ) |
| 292 | load_type = step_definition['load_type'] |
| 293 | if load_type == 'json': |
| 294 | return json.loads(value) |
| 295 | else: |
| 296 | raise ValueError(f'Unsupported load_type: {load_type}') |
| 297 | |
| 298 | |
| 299 | class DumpDataStep(BaseStep): |