diff --git a/src/apps/competitions/models.py b/src/apps/competitions/models.py
index f919ae432..8b45aa9e8 100644
--- a/src/apps/competitions/models.py
+++ b/src/apps/competitions/models.py
@@ -165,6 +165,7 @@ def apply_phase_migration(self, current_phase, next_phase, force_migration=False
                 phase=next_phase,
                 owner=submission.owner,
                 data=submission.data,
+                organization=submission.organization,
             )
             new_submission.save(ignore_submission_limit=True)
             new_submission.start()
@@ -654,7 +655,8 @@ def re_run(self, task=None):
             'has_children': self.has_children,
             'is_specific_task_re_run': is_specific_task_re_run,
             'fact_sheet_answers': self.fact_sheet_answers,
-            'queue': self.phase.competition.queue
+            'queue': self.phase.competition.queue,
+            'organization': self.organization,
         }
         sub = Submission(**submission_arg_dict)
         sub.save(ignore_submission_limit=True)
diff --git a/src/apps/competitions/tasks.py b/src/apps/competitions/tasks.py
index 3d7d8abcb..82a1f60cf 100644
--- a/src/apps/competitions/tasks.py
+++ b/src/apps/competitions/tasks.py
@@ -400,6 +400,7 @@ def _run_submission(submission_pk, task_pks=None, is_scoring=False):
                 task=task,
                 fact_sheet_answers=submission.fact_sheet_answers,
                 queue=queue,
+                organization=submission.organization,
             )
             child_sub.save(ignore_submission_limit=True)
             _send_to_compute_worker(child_sub, is_scoring=False)