diff --git a/pkg/rtc/participant.go b/pkg/rtc/participant.go
index c0cdd53c3..ea8dc260f 100644
--- a/pkg/rtc/participant.go
+++ b/pkg/rtc/participant.go
@@ -571,6 +571,8 @@ func (p *ParticipantImpl) SetMigrateState(s types.MigrateState) {
 		}
 		pendingOffer = p.pendingOffer
 		p.pendingOffer = nil
+		// in case of migration, subscriber data channel will not fire OnOpen callback
+		p.activeCounter.CAS(0, 2)
 	}
 	p.lock.Unlock()
 	if s == types.MigrateStateComplete {