code: def pg_vector_ingest_operator():
      return PgVectorIngestOperator(
          task_id="test_task",
          sql="INSERT INTO test_table VALUES (1, 'abc', '');",
          conn_id="your_postgres_conn_id",
      )
  
imports: from __future__ import annotations
  from unittest.mock import Mock, patch
  import pytest
  from airflow.providers.pgvector.operators.pgvector import PgVectorIngestOperator
label_desc: Use image node_id 1 for calling a global function with example usage: pg_vector_ingest_operator() and returns: PgVectorIngestOperator