1 files changed, 4 insertions, 1 deletions
diff --git a/src/mongo/db/pipeline/document_source_lookup_change_post_image.h b/src/mongo/db/pipeline/document_source_lookup_change_post_image.h
index 18d38b52fdb..2a4ccc972fb 100644
--- a/src/mongo/db/pipeline/document_source_lookup_change_post_image.h
+++ b/src/mongo/db/pipeline/document_source_lookup_change_post_image.h
@@ -62,9 +62,12 @@ public:
     }
 
     StageConstraints constraints(Pipeline::SplitState pipeState) const final {
+        invariant(pipeState != Pipeline::SplitState::kSplitForShards);
         StageConstraints constraints(StreamType::kStreaming,
                                      PositionRequirement::kNone,
-                                     HostTypeRequirement::kAnyShard,
+                                     pipeState == Pipeline::SplitState::kUnsplit
+                                         ? HostTypeRequirement::kNone
+                                         : HostTypeRequirement::kMongoS,
                                      DiskUseRequirement::kNoDiskUse,
                                      FacetRequirement::kNotAllowed,
                                      ChangeStreamRequirement::kChangeStreamStage);