Priyanka Patil
10/26/2023, 6:57 PMdef create_pipeline(**kwargs) -> Pipeline:
"""
"""
return pipeline(
[
node(
func=lambda *args: None,
inputs=["<catalog entry for the update query>"],
outputs=None,
name="update_table",
),
]
)
This executes the update query successfully, but the pipeline fails because there are no results to be returned.
Is there a workaround for this?
Thank you so much!Juan Luis
10/27/2023, 8:39 AMoutputs=None
should be OK, unless I'm missing somethingPriyanka Patil
11/01/2023, 6:10 PMsqlalchemy.exc.ResourceClosedError: This result object does not return rows. It has been closed automatically.
kedro.io.core.DataSetError: Failed while loading data from data set SQLQueryDataSet(execution_options={}, filepath=None, load_args={}, sql=update tablename set status = 'COMPLETE' where id = 22;).
This result object does not return rows. It has been closed automatically.
update tablename set status = 'COMPLETE' where id = 22 RETURNING tablename.*;
Juan Luis
11/01/2023, 8:03 PM