hooks
The second required parameter for all run
functions is hooks
:
# modules/hello_world.py
import prism.task
import prism.target
class HelloWorld(prism.task.PrismTask):
def run(self, tasks, hooks):
test_str = "Hello, world!"
return test_str
This parameter is an instance of the PrismHooks
class, a high-level interface that lets you quickly and easily talk to external connections without having to write low-level code or use special libraries.
The following hooks are available to Prism users:
hooks.sql()
: for executing SQL code using specific adaptershooks.spark()
: for executing PySpark codehooks.dbt_ref()
: for converting dbt models into Pandas DataFrames
Last updated