diff --git a/dvc/stage/__init__.py b/dvc/stage/__init__.py index 0048c94fb9..61f9c11914 100644 --- a/dvc/stage/__init__.py +++ b/dvc/stage/__init__.py @@ -306,7 +306,12 @@ def remove(self, force=False, remove_outs=True, purge=True): @rwlocked(read=["deps"], write=["outs"]) def reproduce(self, interactive=False, **kwargs): if not (kwargs.get("force", False) or self.changed()): - logger.info("Stage '%s' didn't change, skipping", self.addressing) + if not isinstance(self, PipelineStage) and self.is_data_source: + logger.info("'%s' didn't change, skipping", self.addressing) + else: + logger.info( + "Stage '%s' didn't change, skipping", self.addressing + ) return None msg = (