How to define DLT table with cyclic reference
Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
07-03-2024 02:46 AM
@Dlt.table
def table_A():
return (
dlt.read_stream(...)
)
@dlt.table
def table_join_A_and_C():
df_A = dlt.read_stream(table_A)
df_C = dlt.read_stream(table_C)
return (
....df_A.join(df_C)
)
@dlt.table
def table_C():
return (
dlt.read_stream(table_join_A_and_C).....
)
I got an error when defining DLT like above. Does DLT support cyclic reference?
Thanks in advance.