diff --git a/snakemake/dag.py b/snakemake/dag.py
index d3b27af4f..12f99175d 100755
--- a/snakemake/dag.py
+++ b/snakemake/dag.py
@@ -2273,7 +2273,7 @@ def get_outputs_with_changes(self, change_type, include_needrun=True):
         changed = list(chain(*map(is_changed, self.jobs)))
         if change_type == "code":
             for job in self.jobs:
-                if not job.is_group():
+                if not job.is_group() and (include_needrun or not self.needrun(job)):
                     changed.extend(list(job.outputs_older_than_script_or_notebook()))
         return changed