Intermediate changes

commit_hash:09395197ee7b5fe0fedb7f40787986adc8ba8abb

9 files changed, 15 insertions, 15 deletions

diff --git a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.cfg b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.cfg
index 62b2a5fe18f..d575d2a0c92 100644
--- a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.cfg
+++ b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.cfg
@@ -2,4 +2,4 @@ in Input input.txt
 out Output output.txt
 res result.txt
 udf python3_udf
-providers dummy
+providers yt
diff --git a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.sql b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.sql
index 0f5cd0b0c6b..71ad92d19da 100644
--- a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.sql
+++ b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.sql
@@ -8,7 +8,7 @@ GROUP BY Length(key) as skey);
 $udfScript = @@
 def f(input,x):
    for i in list(input):
-      d = i.__dict__
+      d = {name: getattr(i, name) for name in i.__class__.__match_args__}
       d["pass"] = x
       yield d
 @@;
diff --git a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.yql b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.yql
index 3df99f0f47d..dc7c70cea68 100644
--- a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.yql
+++ b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.yql
@@ -28,7 +28,7 @@
             (let inputType (CallableArgumentType (TypeOf (ScriptUdf 'Python3 '"f" (CallableType '() '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"skey" (DataType 'Uint32))))) '((DataType 'Int32))) (String '@@
 def f(input,x):
    for i in list(input):
-      d = i.__dict__
+      d = {name: getattr(i, name) for name in i.__class__.__match_args__}
       d["pass"] = x
       yield d
 @@))) '0))
@@ -36,7 +36,7 @@ def f(input,x):
             (return (Apply (ScriptUdf 'Python3 '"f" (CallableType '() '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"skey" (DataType 'Uint32))))) '((DataType 'Int32))) (String '@@
 def f(input,x):
    for i in list(input):
-      d = i.__dict__
+      d = {name: getattr(i, name) for name in i.__class__.__match_args__}
       d["pass"] = x
       yield d
 @@)) inputRowsList (Int32 '"1")))
@@ -49,7 +49,7 @@ def f(input,x):
         (let inputType (CallableArgumentType (TypeOf (ScriptUdf 'Python3 '"f" (CallableType '() '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((DataType 'Int32))) (String '@@
 def f(input,x):
    for i in list(input):
-      d = i.__dict__
+      d = {name: getattr(i, name) for name in i.__class__.__match_args__}
       d["pass"] = x
       yield d
 @@))) '0))
@@ -57,7 +57,7 @@ def f(input,x):
         (return (Apply (ScriptUdf 'Python3 '"f" (CallableType '() '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((DataType 'Int32))) (String '@@
 def f(input,x):
    for i in list(input):
-      d = i.__dict__
+      d = {name: getattr(i, name) for name in i.__class__.__match_args__}
       d["pass"] = x
       yield d
 @@)) inputRowsList (Int32 '"2")))
diff --git a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterReduce.cfg b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterReduce.cfg
index 62b2a5fe18f..d575d2a0c92 100644
--- a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterReduce.cfg
+++ b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterReduce.cfg
@@ -2,4 +2,4 @@ in Input input.txt
 out Output output.txt
 res result.txt
 udf python3_udf
-providers dummy
+providers yt
diff --git a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterReduce.sql b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterReduce.sql
index f0bd1ff3ba0..e15ee6feebf 100644
--- a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterReduce.sql
+++ b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterReduce.sql
@@ -8,7 +8,7 @@ GROUP BY Length(key) as skey);
 $udfScript = @@
 def f(input,x):
    for i in list(input):
-      d = i.__dict__
+      d = {name: getattr(i, name) for name in i.__class__.__match_args__}
       d["pass"] = x
       yield d
 @@;
diff --git a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterReduce.yql b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterReduce.yql
index 3e8637fc543..2143f06bf27 100644
--- a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterReduce.yql
+++ b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterReduce.yql
@@ -26,7 +26,7 @@
         (let inputType (CallableArgumentType (TypeOf (ScriptUdf 'Python3 '"f" (CallableType '() '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"skey" (DataType 'Uint32))))) '((DataType 'Int32))) (String '@@
 def f(input,x):
    for i in list(input):
-      d = i.__dict__
+      d = {name: getattr(i, name) for name in i.__class__.__match_args__}
       d["pass"] = x
       yield d
 @@))) '0))
@@ -34,7 +34,7 @@ def f(input,x):
         (return (Apply (ScriptUdf 'Python3 '"f" (CallableType '() '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"skey" (DataType 'Uint32))))) '((DataType 'Int32))) (String '@@
 def f(input,x):
    for i in list(input):
-      d = i.__dict__
+      d = {name: getattr(i, name) for name in i.__class__.__match_args__}
       d["pass"] = x
       yield d
 @@)) inputRowsList (Int32 '"1")))
diff --git a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseMapAfterLReduce.cfg b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseMapAfterLReduce.cfg
index 62b2a5fe18f..d575d2a0c92 100644
--- a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseMapAfterLReduce.cfg
+++ b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseMapAfterLReduce.cfg
@@ -2,4 +2,4 @@ in Input input.txt
 out Output output.txt
 res result.txt
 udf python3_udf
-providers dummy
+providers yt
diff --git a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseMapAfterLReduce.sql b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseMapAfterLReduce.sql
index c87931cafde..d3690a17e43 100644
--- a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseMapAfterLReduce.sql
+++ b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseMapAfterLReduce.sql
@@ -8,7 +8,7 @@ GROUP BY Length(key) as skey);
 $udfScript = @@
 def f(input,x):
    for i in list(input):
-      d = i.__dict__
+      d = {name: getattr(i, name) for name in i.__class__.__match_args__}
       d["pass"] = x
       yield d
       
diff --git a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseMapAfterLReduce.yql b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseMapAfterLReduce.yql
index 5656d60fc3a..5495292e2e2 100644
--- a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseMapAfterLReduce.yql
+++ b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseMapAfterLReduce.yql
@@ -28,7 +28,7 @@
             (let inputType (CallableArgumentType (TypeOf (ScriptUdf 'Python3 '"f" (CallableType '() '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"skey" (DataType 'Uint32))))) '((DataType 'Int32))) (String '@@
 def f(input,x):
    for i in list(input):
-      d = i.__dict__
+      d = {name: getattr(i, name) for name in i.__class__.__match_args__}
       d["pass"] = x
       yield d
 
@@ -39,7 +39,7 @@ def f2(a,b,c):
             (return (Apply (ScriptUdf 'Python3 '"f" (CallableType '() '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"skey" (DataType 'Uint32))))) '((DataType 'Int32))) (String '@@
 def f(input,x):
    for i in list(input):
-      d = i.__dict__
+      d = {name: getattr(i, name) for name in i.__class__.__match_args__}
       d["pass"] = x
       yield d
 
@@ -55,7 +55,7 @@ def f2(a,b,c):
         (let res (Apply (ScriptUdf 'Python3 '"f2" (CallableType '() '((StructType '('"a" (DataType 'Uint32)) '('"b" (DataType 'Uint64)) '('"c" (DataType 'Int32)))) '((DataType 'Uint32) 'skey) '((DataType 'Uint64) 'cnt) '((DataType 'Int32) 'pass)) (String '@@
 def f(input,x):
    for i in list(input):
-      d = i.__dict__
+      d = {name: getattr(i, name) for name in i.__class__.__match_args__}
       d["pass"] = x
       yield d