Я пытаюсь упростить свой код в Palantir. Моя идея состоит в том, чтобы использовать цикл с f-строкой, чтобы упростить процесс, вместо того, чтобы писать X раз один и тот же код с разными числами вывода/source_df.
Это мой код:
@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: Parameter 'inputs' of transform Transform(myproject.datasets.list_of_tables:compute) is not a transforms.api.Param
Подробнее здесь: https://stackoverflow.com/questions/790 ... n-palantir
