Skip to content

Commit 0ec4d5b

Browse files
update
Co-authored-by: Thomas Chow <[email protected]>
1 parent 99ef105 commit 0ec4d5b

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

api/python/ai/chronon/repo/dag_builder.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -55,10 +55,12 @@ def to_dependency(node: Union[Source, GroupBy, JoinPart, BootstrapPart], lag: in
5555
min_end_cutoff = None
5656
max_start_cutoff = None
5757
for source_dep in source_deps:
58-
if min_end_cutoff is None or min_end_cutoff > source_dep.endCutOff:
59-
min_end_cutoff = source_dep.endCutOff
60-
if max_start_cutoff is None or max_start_cutoff < source_dep.startCutOff:
61-
max_start_cutoff = source_dep.startCutOff
58+
if source_dep.endCutoff is not None:
59+
if min_end_cutoff is None or min_end_cutoff > source_dep.endCutOff:
60+
min_end_cutoff = source_dep.endCutOff
61+
if source_dep.startCutOff is not None:
62+
if max_start_cutoff is None or max_start_cutoff < source_dep.startCutOff:
63+
max_start_cutoff = source_dep.startCutOff
6264

6365
return TableDependency(
6466
tableInfo=node.metaData.executionInfo.outputTableInfo,

0 commit comments

Comments
 (0)