Black Spy
07/04/2022, 7:37 AMAnna Geller
07/04/2022, 11:51 AMingest_metadata
is a function decorated with flow:
from prefect_openmetadata.flows import ingest_metadata
config = """
source:
type: sample-data
serviceName: sample_data
serviceConnection:
config:
type: SampleData
sampleDataFolder: "example-data"
sourceConfig: {}
sink:
type: metadata-rest
config: {}
workflowConfig:
openMetadataServerConfig:
hostPort: <http://localhost:8585/api>
authProvider: no-auth
"""
if __name__ == "__main__":
ingest_metadata(config)
there are many more examples in the docs here