Skip to content

Create routing logic for discover and check workflow #21291

Closed
@xiaohansong

Description

@xiaohansong

Now these workflow use the following logic to define the task queue name (simply looking up the job type and translate that to string).

https://github.com/airbytehq/airbyte/blob/master/airbyte-commons-temporal/src/main/java/io/airbyte/commons/temporal/TemporalWorkflowUtils.java#L52

To separate these two workflows into dataplane level we need to implement a routing logic to determine which queue it needs to go based on job id. Once that helper function is implemented, change these functions to make sure when we start the workflow we used this routing logic:

https://github.com/airbytehq/airbyte/blob/master/airbyte-commons-temporal/src/main/java/io/airbyte/commons/temporal/TemporalClient.java#L339-L373

Metadata

Metadata

Assignees

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions