Skip to content

Using openmetada to configure and deploy dagster for ingestion #7762

Description

@slamer59

Is your feature request related to a problem? Please describe.
For now, only Airflow can be setup through the UI.

image

Support alternative orchestrators for metadata ingestion #4986

Describe the solution you'd like
I want to be able to deploy dagster and select it in OpenMetadata UI.

We might want to integrate [as a service extending the interface. ](OpenMetadata/AirflowRESTClient.java at main · open-metadata/OpenMetadata)

Mapping API
This is the dagster API

deployPipeline : I don't think there is something similar in dagster. What is the purpose of it ? Usually we create a pipeline and create a Docker image. A daemon is connected through gRPC. We add this pipeline in a configfile ConfigMap.

deletePipeline : we remove it from the ConfigMap

runPipeline : correspond to LaunchRunMutation

toggleIngestion : What is the purpose of this ? We can activate schedulers with Graphql API

getPipelineStatus : One way RunsQuery you have all runs but we can filter for OpenMetadata secific run. FilteredRunsQuery

getServiceStatus and testConnection : health check of daemon and pipeline is possible.

killIngestion : TerminateRun mutation

requestGetHostIP : What is it for ?

getLastIngestionLogs : What is it for ? We can requests metadata asociated to a pipeline.

Describe alternatives you've considered
Today one way is to do something similar to this
Not installing Airflow will through error in the UI.

Additional context
This follows this discussion
https://openmetadata.slack.com/archives/C02AZGN0WKY/p1664297118682629

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions