def METHOD_NAME():
    extractor = Extractors().get_extractor_class(ExampleOperator)
    assert extractor is DefaultExtractor
    metadata = extractor(ExampleOperator(task_id="test")).extract()
    task_instance = mock.MagicMock()
    metadata_on_complete = extractor(
        ExampleOperator(task_id="test")
    ).extract_on_complete(task_instance=task_instance)
    assert metadata == TaskMetadata(
        name="adhoc_airflow.test",
        inputs=INPUTS,
        outputs=OUTPUTS,
        run_facets=RUN_FACETS,
        job_facets=JOB_FACETS,
    )
    assert metadata_on_complete == TaskMetadata(
        name="adhoc_airflow.test",
        inputs=INPUTS,
        outputs=OUTPUTS,
        run_facets=RUN_FACETS,
        job_facets=FINISHED_FACETS,
    )