Skip to content

Commit e557050

Browse files
committed
Temporary debug logs
1 parent aa3ce0e commit e557050

2 files changed

Lines changed: 18 additions & 1 deletion

File tree

src/integration-tests/WorkflowExecutor.complete.test.ts

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,13 @@ describe("WorkflowExecutor Complete Coverage", () => {
6161
const executionsToCleanup: string[] = [];
6262

6363
beforeAll(async () => {
64+
const t0 = Date.now();
65+
const log = (step: string) => {
66+
console.log(`[WorkflowExecutor.complete beforeAll] ${step} (+${Date.now() - t0}ms total)`);
67+
};
68+
6469
client = await createClientWithRetry();
70+
log("createClientWithRetry");
6571
executor = new WorkflowExecutor(client);
6672
metadataClient = new MetadataClient(client);
6773
_taskClient = new TaskClient(client);
@@ -76,6 +82,7 @@ describe("WorkflowExecutor Complete Coverage", () => {
7682
retryLogic: "FIXED",
7783
retryDelaySeconds: 0,
7884
});
85+
log("registerTask");
7986

8087
// Register WAIT workflow (blocks until signal)
8188
const waitWfDef: WorkflowDef = {
@@ -94,6 +101,7 @@ describe("WorkflowExecutor Complete Coverage", () => {
94101
};
95102
await executor.registerWorkflow(true, waitWfDef);
96103
workflowsToCleanup.push({ name: waitWfName, version: 1 });
104+
log("registerWorkflow(waitWf)");
97105

98106
// Register SET_VARIABLE workflow (completes instantly)
99107
const simpleWfDef: WorkflowDef = {
@@ -114,6 +122,7 @@ describe("WorkflowExecutor Complete Coverage", () => {
114122
};
115123
await executor.registerWorkflow(true, simpleWfDef);
116124
workflowsToCleanup.push({ name: simpleWfName, version: 1 });
125+
log("registerWorkflow(simpleWf)");
117126

118127
// Register SIMPLE task workflow (blocks on task poll)
119128
const taskWfDef: WorkflowDef = {
@@ -129,7 +138,8 @@ describe("WorkflowExecutor Complete Coverage", () => {
129138
};
130139
await executor.registerWorkflow(true, taskWfDef);
131140
workflowsToCleanup.push({ name: taskWfName, version: 1 });
132-
});
141+
log("registerWorkflow(taskWf)");
142+
}, 300000);
133143

134144
afterEach(async () => {
135145
for (const execId of executionsToCleanup) {

src/sdk/createConductorClient/createConductorClient.ts

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ import type { OrkesApiConfig } from "../types";
88
import { createClient } from "../../open-api/generated/client";
99
import { addResourcesBackwardCompatibility } from "./helpers/addResourcesBackwardCompatibility";
1010

11+
let hasLoggedServerUrl = false;
12+
1113
/**
1214
* Creates a Conductor client with authentication and configuration
1315
*
@@ -38,6 +40,11 @@ export const createConductorClient = async (
3840

3941
if (!serverUrl) throw new Error("Conductor server URL is not set");
4042

43+
if (!hasLoggedServerUrl) {
44+
hasLoggedServerUrl = true;
45+
console.log("[Conductor SDK] serverUrl:", serverUrl);
46+
}
47+
4148
const baseFetchFn = await resolveFetchFn(customFetch, {
4249
maxHttpConnections: maxHttp2Connections,
4350
connectTimeoutMs,

0 commit comments

Comments
 (0)