code: def test_execute(self, mock_run_cli):
      pig_opts = "-x mapreduce"
      operator = PigOperator(
          pig=PIG, pig_opts=pig_opts, task_id=TEST_TASK_ID
      )
      operator.execute(context=TEST_CONTEXT_ID)
  
      mock_run_cli.assert_called_once_with(pig=PIG, pig_opts=pig_opts)
  
file_path: airflow/tests/providers/apache/pig/operators/test_pig.py
imports: from __future__ import annotations
  from unittest import mock
  import pytest
  from airflow.providers.apache.pig.hooks.pig import PigCliHook
  from airflow.providers.apache.pig.operators.pig import PigOperator
label_desc: Use image node_id 2 for calling the TestPigOperator obj's underlying member method code with example usage: obj.test_execute(mock_run_cli) without return types