code: def test_uri_with_scheme():
      dataset = Dataset(uri="s3://example_dataset")
      EmptyOperator(task_id="task1", outlets=[dataset])
  
imports: from __future__ import annotations
  import pytest
  from airflow.datasets import Dataset
  from airflow.operators.empty import EmptyOperator
label_desc: Use image node_id 2 for calling a global function with example usage: test_uri_with_scheme() without return types