Skip to content

Commit 4e7b865

Browse files
varant-zlaiezvz
andauthored
Fixing partition spec column setting in table deps (#782)
## Summary Setting the partition spec correctly in table dependencies ## Checklist - [ ] Added Unit Tests - [x] Covered by existing CI - [ ] Integration tested - [ ] Documentation update <!-- This is an auto-generated comment: release notes by coderabbit.ai --> ## Summary by CodeRabbit - **Bug Fixes** - Corrected the partition column used for snapshot table dependencies to ensure accurate data partitioning. <!-- end of auto-generated comment: release notes by coderabbit.ai --> Co-authored-by: ezvz <[email protected]>
1 parent 919b845 commit 4e7b865

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

api/src/main/scala/ai/chronon/api/planner/TableDependencies.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ object TableDependencies {
6060
.setTableInfo(
6161
new TableInfo()
6262
.setTable(jp.groupBy.metaData.outputTable)
63-
.setPartitionColumn("dt")
63+
.setPartitionColumn(spec.column)
6464
.setPartitionFormat(spec.format)
6565
.setPartitionInterval(WindowUtils.hours(spec.spanMillis))
6666
)

0 commit comments

Comments
 (0)