Атрибут временного поиска по ключевым словам не работает ⇐ Python

[Anonymous]

У меня есть список созданных атрибутов поиска:

Код: Выделить всё

keys = [
SearchAttributeKey.for_keyword(key)
for key in ('inquiryId', 'personId', 'flowId', 'reservationId', 'workspaceId', 'segmentId')
]
await client.operator_service.add_search_attributes(
AddSearchAttributesRequest(
namespace=client.namespace,
search_attributes={
key.name: IndexedValueType.ValueType(key.indexed_value_type)
for key in keys_to_create
},
),
)

Я создаю выполнение рабочего процесса со значениями этих атрибутов:

Код: Выделить всё

await self._temporal_client.start_workflow(
ExecuteFlowWorkflow.run,
flow,
id=f"execute-flow-{uuid4()}",
task_queue=self._temporal_settings.task_queue,
search_attributes=TypedSearchAttributes([
SearchAttributePair(SearchAttributeKey.for_text(f"flowId"), str(flow.id)),
SearchAttributePair(SearchAttributeKey.for_text(f"personId"), str(person_id)),
SearchAttributePair(SearchAttributeKey.for_text(f"reservationId"), str(reservation_id)),
SearchAttributePair(SearchAttributeKey.for_text(f"workspaceId"), str(workspace_id)),
])
)

Если вы распечатаете все выполнения воркфлоу, вы заметите, что эти атрибуты имеют значения списка, что вызывает у меня некоторые подозрения:

Код: Выделить всё

async for workflow in temporal_client.list_workflows(query='WorkflowType="ExecuteFlowWorkflow"', page_size=10000):
if workflow.status != WorkflowExecutionStatus.RUNNING:
continue
print(workflow.search_attributes)

# OUTPUT:
{'flowId': ['018fcbab-6642-7b8a-ab59-43ded6b563bb'], 'workspaceId': ['018c1bec-682c-7518-992a-ec875e8efe63'], 'reservationId': ['0190d10c-ba1e-759c-a9a1-590845cb120a'], 'personId': ['0190d10c-b8c7-7ad6-a0ff-cf5cd3d2b0a5']}

И когда я пытаюсь получить рабочие процессы с workspaceId = 018c1bec-682c-7518-992a-ec875e8efe63, я ничего не получаю:

Код: Выделить всё

async for workflow in temporal_client.list_workflows(query=f'workspaceId="018c1bec-682c-7518-992a-ec875e8efe63"'):
print(workflow)
# No output

Кроме того, он не работает во временном пользовательском интерфейсе. Что я сделал не так?

Подробнее здесь: https://stackoverflow.com/questions/787 ... s-not-work