code: def fetch_tweets():
      """
      This task should call Twitter API and retrieve tweets from yesterday from and to for the four twitter
      users (Twitter_A,..,Twitter_D) There should be eight csv output files generated by this task and naming
      convention is direction(from or to)_twitterHandle_date.csv
      """
  
file_path: airflow/tests/system/providers/apache/hive/example_twitter_dag.py
imports: from __future__ import annotations
  import os
  from datetime import date, datetime, timedelta
  from airflow import DAG
  from airflow.decorators import task
  from airflow.operators.bash import BashOperator
  from airflow.providers.apache.hive.operators.hive import HiveOperator
  from tests.system.utils import get_test_run
label_desc: Use image node_id 1 for calling a global function with example usage: fetch_tweets() without return types