| 297 | |
| 298 | |
| 299 | class DumpDataStep(BaseStep): |
| 300 | NAME = 'dump-data' |
| 301 | |
| 302 | def run_step(self, step_definition, parameters): |
| 303 | var_resolver = VariableResolver() |
| 304 | value = var_resolver.resolve_variables( |
| 305 | parameters, |
| 306 | step_definition['value'], |
| 307 | ) |
| 308 | dump_type = step_definition['dump_type'] |
| 309 | if dump_type == 'json': |
| 310 | return json.dumps(value) |
| 311 | else: |
| 312 | raise ValueError(f'Unsupported load_type: {dump_type}') |
| 313 | |
| 314 | |
| 315 | class VariableResolver: |