Skip to content

Unable to set different workflows to the same task queue #19

Open
@pvolchak

Description

@pvolchak

When assigning 2 different activities to the same task queue and try running one of the workflows as a child workflow or just run one of them separately i get the following error: Unknown workflow type "TestNumberDefinition". Known types are [TestNumberReversedDefinition]. my application yaml looks like such for the workflows
workflows: testNumberReversed: taskQueue: testNumber testNumber: taskQueue: testNumber testString: taskQueue: testString activityStubDefaults: scheduleToCloseTimeout: PT30S

my test number and test number reversed look like such

`@Component
@TemporalWorkflow("testNumberReversed")
open class TestNumberReversed: TestNumberReversedDefinition {

override fun someNumberReverse(): Int {
    val options: ChildWorkflowOptions = ChildWorkflowOptions
        .newBuilder()
        .setTaskQueue("testNumber")
        .setParentClosePolicy(ParentClosePolicy.PARENT_CLOSE_POLICY_ABANDON)
        .build()

    val child = Workflow.newChildWorkflowStub(TestNumberDefinition::class.java, options)
    val childExecution = Async.function(child::someNumber)
    var num = (childExecution.get().toDouble() * 100).toInt()
    var reversed = 0

    while (num != 0) {
        val digit = num % 10
        reversed = reversed * 10 + digit
        num /= 10
    }

    return reversed
}

}

@WorkflowInterface
interface TestNumberReversedDefinition {
@WorkflowMethod fun someNumberReverse(): Int
}`

`@Component
@TemporalWorkflow("testNumber")
open class TestNumber: TestNumberDefinition {

@ActivityStub lateinit var numberActivity: NumberActivityDefinition

override fun someNumber(): Double {
    return numberActivity.getSomeNumber()
}

}

@WorkflowInterface
interface TestNumberDefinition {
@WorkflowMethod fun someNumber(): Double
}`

Metadata

Metadata

Assignees

Labels

bugSomething isn't working

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions