rhythmic-lizard-91902
11/08/2023, 9:13 PMelasticsearch.NotFoundError: NotFoundError(404, "{'_index': 'enabled_entities', '_id': 'Promise(node:.entity_id)', 'found': False}")
But I want to undersntand the Promise thing.In this scenario, entity_id in a parameter and not a result from a task, simplified, this is the workflow/class interaction:
def some_workflow(entity_id: int):
instanse = SomeClass(entity_id=entity_id)
class SomeClass:
def __init__(self, entity_id: int):
lb = AnotherClass()
lb.process(entity_id)
The error above, happens on lb.process that basically calls to elastic to get some data. Why flyte is passing the parameter as Promise?tall-lock-23197
SomeClass
in your Flyte pipeline?rhythmic-lizard-91902
11/09/2023, 11:37 AM@workflow
def some_workflow(entity_id: int):
instanse = SomeClass(entity_id=entity_id)
anotherTass()
class SomeClass:
def __init__(self, entity_id: int):
lb = AnotherClass()
lb.process(entity_id) #fails here
@tall-lock-23197 like thistall-lock-23197