diff --git a/ydb/library/yql/dq/transform/yql_common_dq_transform.cpp b/ydb/library/yql/dq/transform/yql_common_dq_transform.cpp
index 5db4376a381e..f3c03f57b0e7 100644
--- a/ydb/library/yql/dq/transform/yql_common_dq_transform.cpp
+++ b/ydb/library/yql/dq/transform/yql_common_dq_transform.cpp
@@ -45,8 +45,8 @@ class TCommonDqTaskTransform {
 };
 
 TTaskTransformFactory CreateCommonDqTaskTransformFactory() {
-    return [] (const THashMap<TString, TString>& taskParams, const IFunctionRegistry* funcRegistry) -> TCallableVisitFuncProvider {
-        Y_UNUSED(taskParams);
+    return [] (const TTaskTransformArguments& args, const IFunctionRegistry* funcRegistry) -> TCallableVisitFuncProvider {
+        Y_UNUSED(args);
         return TCommonDqTaskTransform(*funcRegistry);
     };
 }
diff --git a/ydb/library/yql/providers/dq/runtime/task_command_executor.cpp b/ydb/library/yql/providers/dq/runtime/task_command_executor.cpp
index e07d1a98a7e6..a4f63f230d79 100644
--- a/ydb/library/yql/providers/dq/runtime/task_command_executor.cpp
+++ b/ydb/library/yql/providers/dq/runtime/task_command_executor.cpp
@@ -751,7 +751,7 @@ class TTaskCommandExecutor {
             }
             settings.OptLLVM = DqConfiguration->OptLLVM.Get().GetOrElse("");
 
-            Ctx.FuncProvider = TaskTransformFactory(taskParams, Ctx.FuncRegistry);
+            Ctx.FuncProvider = TaskTransformFactory({taskParams, settings.ReadRanges}, Ctx.FuncRegistry);
 
             Y_ABORT_UNLESS(!Alloc);
             Y_ABORT_UNLESS(FunctionRegistry);
diff --git a/ydb/library/yql/providers/dq/task_runner/tasks_runner_local.cpp b/ydb/library/yql/providers/dq/task_runner/tasks_runner_local.cpp
index 983065c4f6f1..ca98d6aacefe 100644
--- a/ydb/library/yql/providers/dq/task_runner/tasks_runner_local.cpp
+++ b/ydb/library/yql/providers/dq/task_runner/tasks_runner_local.cpp
@@ -267,7 +267,7 @@ class TLocalFactory: public IProxyFactory {
                 YQL_CLOG(DEBUG, ProviderDq) << message;
             };
         }
-        ctx.FuncProvider = TaskTransformFactory(settings.TaskParams, ctx.FuncRegistry);
+        ctx.FuncProvider = TaskTransformFactory({settings.TaskParams, settings.ReadRanges}, ctx.FuncRegistry);
         return MakeDqTaskRunner(alloc, ctx, settings, logger);
     }
 
diff --git a/ydb/library/yql/providers/ydb/comp_nodes/yql_ydb_dq_transform.cpp b/ydb/library/yql/providers/ydb/comp_nodes/yql_ydb_dq_transform.cpp
index 480f24a68001..a281080656a4 100644
--- a/ydb/library/yql/providers/ydb/comp_nodes/yql_ydb_dq_transform.cpp
+++ b/ydb/library/yql/providers/ydb/comp_nodes/yql_ydb_dq_transform.cpp
@@ -51,8 +51,8 @@ class TYdbDqTaskTransform {
 };
 
 TTaskTransformFactory CreateYdbDqTaskTransformFactory() {
-    return [] (const THashMap<TString, TString>& taskParams, const IFunctionRegistry* funcRegistry) -> TCallableVisitFuncProvider {
-        return TYdbDqTaskTransform(taskParams, *funcRegistry);
+    return [] (const TTaskTransformArguments& args, const IFunctionRegistry* funcRegistry) -> TCallableVisitFuncProvider {
+        return TYdbDqTaskTransform(args.TaskParams, *funcRegistry);
     };
 }