| 504 | } |
| 505 | |
| 506 | func RunQRepFlowWorkflow(t *testing.T, tc client.Client, config *protos.QRepConfig) WorkflowRun { |
| 507 | t.Helper() |
| 508 | |
| 509 | client, err := NewApiClient() |
| 510 | require.NoError(t, err) |
| 511 | res, err := client.CreateQRepFlow(t.Context(), &protos.CreateQRepFlowRequest{QrepConfig: config}) |
| 512 | require.NoError(t, err) |
| 513 | return WorkflowRun{ |
| 514 | WorkflowRun: tc.GetWorkflow(t.Context(), res.WorkflowId, ""), |
| 515 | c: tc, |
| 516 | } |
| 517 | } |
| 518 | |
| 519 | func GetOwnersSchema() *types.QRecordSchema { |
| 520 | return &types.QRecordSchema{ |