hooks.get_cursor(...)
Function used to retrieve a cursor from an adapter's connection
hooks.get_cursor(adapter_name: str)
Parameters
adapter_name: the adapter in the projects profile YML whose connection you want to retrieve
Returns:
A database cursor associated with the adapter's connection
Note that this is only available for the following adapters:
Postgres
Redshift
Snowflake
Trino
from prism.task import PrismTask
class SqlTask(PrismTask)
def run(self, tasks, hooks):
with cursor as hooks.get_connection(adapter_name="<ADAPTER_NAME">):
cursor.execute("...")
cursor.close()
return ...
from prism.decorators import task
@task()
def sql_task(tasks, hooks):
with cursor as hooks.get_connection(adapter_name="<ADAPTER_NAME">):
cursor.execute("...")
cursor.close()
return ...