Skip to content

Commit

Permalink
Don't pass registered_udf_name as argument in batch mode (#434)
Browse files Browse the repository at this point in the history
This fixes an issue where with registered task graphs we would pass the
registered udf name as the first argument instead of ignoring it.
  • Loading branch information
Shelnutt2 authored Jul 12, 2023
1 parent 2648f6d commit a9bce26
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions src/tiledb/cloud/dag/dag.py
Original file line number Diff line number Diff line change
Expand Up @@ -1522,8 +1522,12 @@ def _build_batch_taskgraph(self):
i = 0
for arg in node.args:
i += 1
# Skip if first arg is function
if i == 1 and callable(arg):
continue
# Skip if first arg is registered udf name
if i == 1 and type(arg) == str and "registered_udf_name" in kwargs:
continue
if isinstance(arg, Node):
if node._expand_node_output:
args.append(
Expand Down

0 comments on commit a9bce26

Please sign in to comment.