Это мой код:
Код: Выделить всё
@transform(
output1=Output("output1"),
output2=Output("output2"),
source_df1=Input("source1"),
source_df2=Input("source2")
)
def compute(output1, output2, source_df1, source_df2):
for i in range(1, 1, 3):
f"output{i}".write_dataframe(f"source_df{i}".dataframe().filter(
f"source_df{i}".dataframe().SNAPSHOT_DATE >= "2024-09-18").coalesce(1),
output_format="csv", options={
'compression': 'gzip', 'header': "True"
})
ValueError: «входные данные» параметра преобразования Transform(myproject.datasets.list_of_tables:compute) не являются преобразованиями .api.Param
Подробнее здесь: https://stackoverflow.com/questions/790 ... n-palantir