diff --git a/dlt/cli/pipeline_command.py b/dlt/cli/pipeline_command.py index 8b341f615c..9981fa8493 100644 --- a/dlt/cli/pipeline_command.py +++ b/dlt/cli/pipeline_command.py @@ -263,13 +263,13 @@ def _display_pending_packages() -> Tuple[Sequence[str], Sequence[str]]: fmt.warning("Pipeline does not have a default schema") else: fmt.echo("Found schema with name %s" % fmt.bold(p.default_schema_name)) - format = command_kwargs.get("format") - remove_defaults = command_kwargs.get("remove_defaults") + format_ = command_kwargs.get("format") + remove_defaults_ = command_kwargs.get("remove_defaults") s = p.default_schema - if format == "json": - schema_str = json.dumps(s.to_dict(remove_defaults=remove_defaults), pretty=True) + if format_ == "json": + schema_str = json.dumps(s.to_dict(remove_defaults=remove_defaults_), pretty=True) else: - schema_str = s.to_pretty_yaml(remove_defaults=remove_defaults) + schema_str = s.to_pretty_yaml(remove_defaults=remove_defaults_) fmt.echo(schema_str) if operation == "drop":