Just a friendly reminder to post the code blocks in the thread is possible to make the main channel a bit neater.

No problem at all!

There has to be a little more structure to what is possible to do when/where that is documented somewhere? I seem to have a hard time figuring that out.

#You can modify the task from the task library like this: class PostgresExecute(Task): “”" Task for executing a query against a Postgres database. Args: - **kwargs (dict, optional): additional keyword arguments to pass to the Task constructor “”" def __init__( self, **kwargs ): super().__init__(**kwargs) def run( self, db_name: str = None, user: str = None, host: str = None, port: int = None, query: str = None, data: tuple = None, commit: bool = False, password: str = None, ): “”" Task run method. Executes a query against Postgres database. Args: - query (str, optional): query to execute against database - data (tuple, optional): values to use in query, must be specified using placeholder is query string - commit (bool, optional): set to True to commit transaction, defaults to false - password (str): password used to authenticate; should be provided from a

Secret

task Returns: - None Raises: - ValueError: if query parameter is None or a blank string - DatabaseError: if exception occurs when executing the query “”" if not query: raise ValueError(“A query string must be provided”) # connect to database, open cursor # allow psycopg2 to pass through any exceptions raised conn = pg.connect( dbname=db_name, user=user, password=password, host=host, port=port, ) # try to execute query # context manager automatically rolls back failed transactions try: with conn, conn.cursor() as cursor: executed = cursor.execute(query=query, vars=data) if commit: conn.commit() else: conn.rollback() return executed # ensure connection is closed finally: conn.close()

I think something like this will work for your use case