diff options
| author | xyliganSereja <[email protected]> | 2026-06-08 15:28:49 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2026-06-08 15:28:49 +0300 |
| commit | dc44185465cae6e317ebec01fbbd1d4da7c522cd (patch) | |
| tree | a31972474eb8337c9a7fdebfb23e44d4d043bb2f | |
| parent | 6042cb334610daf374de91ca1aa1feeeadb7bc46 (diff) | |
fixed race (#42082)
Co-authored-by: Matveev Sergei <[email protected]>
| -rw-r--r-- | ydb/core/tx/columnshard/engines/reader/common_reader/iterator/fetching.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/ydb/core/tx/columnshard/engines/reader/common_reader/iterator/fetching.cpp b/ydb/core/tx/columnshard/engines/reader/common_reader/iterator/fetching.cpp index 9a12e1889d7..ab8b0332230 100644 --- a/ydb/core/tx/columnshard/engines/reader/common_reader/iterator/fetching.cpp +++ b/ydb/core/tx/columnshard/engines/reader/common_reader/iterator/fetching.cpp @@ -243,6 +243,7 @@ void TProgramStep::ReportTracing( source->MutableExecutionContext().SetPrevExecutionResult(currentExecutionResult); } +NO_SANITIZE_THREAD TConclusion<bool> TProgramStep::DoExecuteInplace(const std::shared_ptr<IDataSource>& source, const TFetchingScriptCursor& step) const { const bool started = !source->GetExecutionContext().HasProgramIterator(); if (!source->GetExecutionContext().HasProgramIterator()) { |