code: def example_pgvector_dag():
      """Example pgvector DAG demonstrating usage of the PgVectorIngestOperator."""
  
      @task()
      def create_postgres_objects():
          """
          Example task to create PostgreSQL objects including table and installing the vector extension using
          the PgVectorHook.
          """
          pg_hook = PgVectorHook(postgres_conn_id=POSTGRES_CONN_ID)
  
          # Create a table
          columns = [
              "id SERIAL PRIMARY KEY",
              "name VARCHAR(255)",
              "value INTEGER",
              "vector_column vector(3)",
          ]
          pg_hook.create_table(TABLE_NAME, columns)
  
          # Create vector extension
          extension_name = "vector"
          pg_hook.create_extension(extension_name)
  
      # [START howto_operator_pgvector_ingest]
      pgvector_ingest = PgVectorIngestOperator(
          task_id="pgvector_ingest",
          conn_id=POSTGRES_CONN_ID,
          sql=f"INSERT INTO {TABLE_NAME} (name, value, vector_column) "
          f"VALUES ('John Doe', 123, '[1.0, 2.0, 3.0]')",
      )
      # [END howto_operator_pgvector_ingest]
  
      @task()
      def cleanup_postgres_objects():
          """
          Cleanup Postgres objects created in the earlier task.
          """
          pg_hook = PgVectorHook(postgres_conn_id=POSTGRES_CONN_ID)
          pg_hook.truncate_table(TABLE_NAME)
          pg_hook.drop_table(TABLE_NAME)
  
      (
          create_postgres_objects()
          >> pgvector_ingest
          >> cleanup_postgres_objects()
      )
  
imports: from __future__ import annotations
  import pendulum
  from airflow.decorators import dag, task
  from airflow.providers.pgvector.hooks.pgvector import PgVectorHook
  from airflow.providers.pgvector.operators.pgvector import PgVectorIngestOperator
  from tests.system.utils import get_test_run
label_desc: Use image node_id 1 for calling a global function with example usage: example_pgvector_dag() without return types