Skip to content

Commit cbdfe09

Browse files
Fix task_context.input_tables (needed for DB2 input table locking) (#144)
1 parent 9b57f7c commit cbdfe09

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

docs/source/changelog.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,8 @@
77
* Add support for `ExternalTableReference` to point to tables in external (i.e. not managed by `pipedag`) schemas.
88
* Remove support for `ExternalTableReference` that points to table in schema of current stage. I.e. `ExternalTableReference` can only point to tables in external schemas.
99
- Fix polars import in `pyproject.toml` when using OS X with rosetta2
10+
- Bug fix ibm_db2 backend:
11+
* input tables for SQL queries were not locked
1012

1113
## 0.6.10 (2024-02-29)
1214
- Fix bug where a `Task` that was declared lazy but provided a `Table` without a query string would always be cache valid.

src/pydiverse/pipedag/materialize/core.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -588,7 +588,7 @@ def _input_tables_visitor(x):
588588
input_tables.append(x)
589589
return x
590590

591-
deep_map(bound.arguments.values(), _input_tables_visitor)
591+
deep_map(bound.arguments, _input_tables_visitor)
592592
task_context.input_tables = input_tables
593593

594594
# Not found in cache / lazy -> Evaluate Function

0 commit comments

Comments
 (0)