hooks

The second required parameter for all run functions is hooks:

Class-based tasks

# 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

Function-based tasks

# modules/hello_world.py

from prism.decorators import task

@task()
def hello_world(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 adapters

• hooks.spark(): for executing PySpark code

• hooks.dbt_ref(): for converting dbt models into Pandas DataFrames