Skip to content

Commit e600be4

Browse files
GrigoriyPAblinkov
authored andcommitted
YQ-4148 fix build in import branch (#15325)
1 parent d7e6516 commit e600be4

File tree

4 files changed

+6
-6
lines changed

4 files changed

+6
-6
lines changed

ydb/library/yql/dq/transform/yql_common_dq_transform.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,8 +45,8 @@ class TCommonDqTaskTransform {
4545
};
4646

4747
TTaskTransformFactory CreateCommonDqTaskTransformFactory() {
48-
return [] (const THashMap<TString, TString>& taskParams, const IFunctionRegistry* funcRegistry) -> TCallableVisitFuncProvider {
49-
Y_UNUSED(taskParams);
48+
return [] (const TTaskTransformArguments& args, const IFunctionRegistry* funcRegistry) -> TCallableVisitFuncProvider {
49+
Y_UNUSED(args);
5050
return TCommonDqTaskTransform(*funcRegistry);
5151
};
5252
}

ydb/library/yql/providers/dq/runtime/task_command_executor.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -751,7 +751,7 @@ class TTaskCommandExecutor {
751751
}
752752
settings.OptLLVM = DqConfiguration->OptLLVM.Get().GetOrElse("");
753753

754-
Ctx.FuncProvider = TaskTransformFactory(taskParams, Ctx.FuncRegistry);
754+
Ctx.FuncProvider = TaskTransformFactory({taskParams, settings.ReadRanges}, Ctx.FuncRegistry);
755755

756756
Y_ABORT_UNLESS(!Alloc);
757757
Y_ABORT_UNLESS(FunctionRegistry);

ydb/library/yql/providers/dq/task_runner/tasks_runner_local.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -267,7 +267,7 @@ class TLocalFactory: public IProxyFactory {
267267
YQL_CLOG(DEBUG, ProviderDq) << message;
268268
};
269269
}
270-
ctx.FuncProvider = TaskTransformFactory(settings.TaskParams, ctx.FuncRegistry);
270+
ctx.FuncProvider = TaskTransformFactory({settings.TaskParams, settings.ReadRanges}, ctx.FuncRegistry);
271271
return MakeDqTaskRunner(alloc, ctx, settings, logger);
272272
}
273273

ydb/library/yql/providers/ydb/comp_nodes/yql_ydb_dq_transform.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,8 @@ class TYdbDqTaskTransform {
5151
};
5252

5353
TTaskTransformFactory CreateYdbDqTaskTransformFactory() {
54-
return [] (const THashMap<TString, TString>& taskParams, const IFunctionRegistry* funcRegistry) -> TCallableVisitFuncProvider {
55-
return TYdbDqTaskTransform(taskParams, *funcRegistry);
54+
return [] (const TTaskTransformArguments& args, const IFunctionRegistry* funcRegistry) -> TCallableVisitFuncProvider {
55+
return TYdbDqTaskTransform(args.TaskParams, *funcRegistry);
5656
};
5757
}
5858

0 commit comments

Comments
 (0)