@@ -635,6 +635,18 @@ class TNewCdcStreamAtTable: public TSubOperation {
635635
636636}; // TNewCdcStreamAtTable
637637
638+ void DoCreateLock (const TOperationId& opId, const TPath& workingDirPath, const TPath& tablePath,
639+ TVector<ISubOperation::TPtr>& result)
640+ {
641+ auto outTx = TransactionTemplate (workingDirPath.PathString (),
642+ NKikimrSchemeOp::EOperationType::ESchemeOpCreateLock);
643+ outTx.SetFailOnExist (false );
644+ outTx.SetInternal (true );
645+ outTx.MutableLockConfig ()->SetName (tablePath.LeafName ());
646+
647+ result.push_back (CreateLock (NextPartId (opId, result), outTx));
648+ }
649+
638650} // anonymous
639651
640652void DoCreateStream (const NKikimrSchemeOp::TCreateCdcStream& op, const TOperationId& opId, const TPath& workingDirPath, const TPath& tablePath,
@@ -722,18 +734,6 @@ void DoCreatePqPart(const TOperationId& opId, const TPath& streamPath, const TSt
722734
723735namespace {
724736
725- void DoCreateLock (const TOperationId& opId, const TPath& workingDirPath, const TPath& tablePath,
726- TVector<ISubOperation::TPtr>& result)
727- {
728- auto outTx = TransactionTemplate (workingDirPath.PathString (),
729- NKikimrSchemeOp::EOperationType::ESchemeOpCreateLock);
730- outTx.SetFailOnExist (false );
731- outTx.SetInternal (true );
732- outTx.MutableLockConfig ()->SetName (tablePath.LeafName ());
733-
734- result.push_back (CreateLock (NextPartId (opId, result), outTx));
735- }
736-
737737ISubOperation::TPtr RejectOnCdcChecks (const TOperationId& opId, const TPath& streamPath, const bool acceptExisted) {
738738 const auto checks = streamPath.Check ();
739739 checks
0 commit comments