Method queryWorkflow

backend/src/temporal/temporal.service.ts:216–224

* Query a running workflow for state

(input: {
    workflowId: string;
    queryType: string;
    args?: unknown[];
  })

   * Query a running workflow for state
   */
  async queryWorkflow<T = unknown>(input: {
    workflowId: string;
    queryType: string;
    args?: unknown[];
  }): Promise<T> {
    const handle = await this.getWorkflowHandle({ workflowId: input.workflowId });
    this.logger.debug(`Querying workflow ${input.workflowId} with query '${input.queryType}'`);
    return handle.query(input.queryType, ...(input.args ?? []));
  }

  private async getWorkflowHandle(ref: WorkflowRunReference): Promise<WorkflowHandle<any>> {
    const client = await this.getClient();