def METHOD_NAME(get_connection, get_conn, operation, expected):
    get_connection.return_value = CONN
    dag_id = "sftp_dag"
    task_id = "sftp_task"
    task = SFTPOperator(
        task_id=task_id,
        ssh_conn_id=CONN_ID,
        dag=DAG(dag_id),
        start_date=timezone.utcnow(),
        local_filepath=LOCAL_FILEPATH,
        remote_filepath=REMOTE_FILEPATH,
        operation=operation,
    )
    task_metadata = SFTPExtractor(task).extract()
    assert task_metadata.name == f"{dag_id}.{task_id}"
    assert task_metadata.inputs == expected[0]
    assert task_metadata.outputs == expected[1]