diff --git a/apps/api/src/app/events/e2e/bridge-trigger.e2e.ts b/apps/api/src/app/events/e2e/bridge-trigger.e2e.ts
index ed9ef43261e..e92e1ccdc98 100644
--- a/apps/api/src/app/events/e2e/bridge-trigger.e2e.ts
+++ b/apps/api/src/app/events/e2e/bridge-trigger.e2e.ts
@@ -1,6 +1,7 @@
 import axios from 'axios';
 import { expect } from 'chai';
 import { v4 as uuidv4 } from 'uuid';
+import sinon from 'sinon';
 
 import { SubscribersService, UserSession } from '@novu/testing';
 import {
@@ -724,8 +725,9 @@ contexts.forEach((context: Context) => {
        * Delete `preferences` from the Workflow Definition to simulate an old
        * Workflow Definition (i.e. from old Framework version) that doesn't have the `preferences` property.
        */
-      // @ts-ignore - The operand of a 'delete' operator must be optional.
-      delete newWorkflow.definition.preferences;
+      const { preferences, ...rest } = await newWorkflow.discover();
+      // @ts-expect-error - preferences is not part of the resolved object
+      sinon.stub(newWorkflow, 'discover').resolves(rest);
 
       await bridgeServer.start({ workflows: [newWorkflow] });
 
diff --git a/packages/framework/src/client.test.ts b/packages/framework/src/client.test.ts
index 679fd7f29ee..a80064e2359 100644
--- a/packages/framework/src/client.test.ts
+++ b/packages/framework/src/client.test.ts
@@ -26,7 +26,7 @@ describe('Novu Client', () => {
     });
 
     client = new Client({ secretKey: 'some-secret-key' });
-    client.addWorkflows([newWorkflow]);
+    await client.addWorkflows([newWorkflow]);
   });
 
   describe('client constructor', () => {
@@ -185,7 +185,7 @@ describe('Novu Client', () => {
         }));
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       // wait for discovery to finish
       await new Promise((resolve) => {
@@ -301,7 +301,7 @@ describe('Novu Client', () => {
         );
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const discovery = client.discover();
       expect(discovery.workflows).toHaveLength(2);
@@ -355,7 +355,7 @@ describe('Novu Client', () => {
         }
       );
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const emailEvent: Event = {
         action: PostActionEnum.PREVIEW,
@@ -381,7 +381,7 @@ describe('Novu Client', () => {
     it('should sanitize the step result of all delivery channel step types', async () => {
       const script = `<script>alert('Hello there')</script>`;
 
-      client.addWorkflows([
+      await client.addWorkflows([
         workflow('test-workflow', async ({ step }) => {
           await step.email('send-email', async () => ({
             body: `Start of body. ${script}`,
@@ -409,7 +409,7 @@ describe('Novu Client', () => {
     it('should not sanitize the step result of custom step type', async () => {
       const script = `<script>alert('Hello there')</script>`;
 
-      client.addWorkflows([
+      await client.addWorkflows([
         workflow('test-workflow', async ({ step }) => {
           await step.custom(
             'send-email',
@@ -468,7 +468,7 @@ describe('Novu Client', () => {
         controls: {},
       };
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const emailExecutionResult = await client.executeWorkflow(emailEvent);
 
@@ -564,7 +564,7 @@ describe('Novu Client', () => {
         }
       );
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const emailEvent: Event = {
         action: PostActionEnum.EXECUTE,
@@ -633,7 +633,7 @@ describe('Novu Client', () => {
         }
       );
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -699,7 +699,7 @@ describe('Novu Client', () => {
         }
       );
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -762,7 +762,7 @@ describe('Novu Client', () => {
         }
       );
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -825,7 +825,7 @@ describe('Novu Client', () => {
         }
       );
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -888,7 +888,7 @@ describe('Novu Client', () => {
         }
       );
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -935,7 +935,7 @@ describe('Novu Client', () => {
         );
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -981,7 +981,7 @@ describe('Novu Client', () => {
         );
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const emailEvent: Event = {
         action: PostActionEnum.EXECUTE,
@@ -1030,7 +1030,7 @@ describe('Novu Client', () => {
         );
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const emailEvent: Event = {
         action: PostActionEnum.EXECUTE,
@@ -1061,7 +1061,7 @@ describe('Novu Client', () => {
         await step.email('send-email', async () => ({ body: 'Test Body', subject: 'Subject' }));
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -1100,7 +1100,7 @@ describe('Novu Client', () => {
         });
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -1153,7 +1153,7 @@ describe('Novu Client', () => {
         });
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -1207,7 +1207,7 @@ describe('Novu Client', () => {
         });
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -1249,7 +1249,7 @@ describe('Novu Client', () => {
         await step.email('inactive-step-id', async () => ({ body: 'Test Body', subject: 'Subject' }));
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -1277,7 +1277,7 @@ describe('Novu Client', () => {
         });
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -1306,7 +1306,7 @@ describe('Novu Client', () => {
         });
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -1344,7 +1344,7 @@ describe('Novu Client', () => {
         });
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -1386,7 +1386,7 @@ describe('Novu Client', () => {
         }
       );
 
-      client.addWorkflows([workflowMock]);
+      await client.addWorkflows([workflowMock]);
 
       const event: Event = {
         action: PostActionEnum.PREVIEW,
@@ -1410,7 +1410,7 @@ describe('Novu Client', () => {
         await step.email('send-email', async () => ({ body: 'Test Body', subject: 'Subject' }));
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.PREVIEW,
@@ -1469,7 +1469,7 @@ describe('Novu Client', () => {
         await step.inApp('send-in-app', async () => ({ body: 'Test Body', subject: 'Subject' }));
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.PREVIEW,
@@ -1508,7 +1508,7 @@ describe('Novu Client', () => {
         });
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.PREVIEW,
@@ -1571,7 +1571,7 @@ describe('Novu Client', () => {
         }
       );
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.PREVIEW,
@@ -1656,7 +1656,7 @@ describe('Novu Client', () => {
         }
       );
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.PREVIEW,
@@ -1713,7 +1713,7 @@ describe('Novu Client', () => {
         await step.email('send-email', async () => ({ body: 'Test Body', subject: 'Subject' }));
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       // @ts-expect-error - no workflow id
       const event2: Event = {
@@ -1730,7 +1730,7 @@ describe('Novu Client', () => {
         await step.email('send-email', async () => ({ body: 'Test Body', subject: 'Subject' }));
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -1750,7 +1750,7 @@ describe('Novu Client', () => {
         await step.email('send-email', async () => ({ body: 'Test Body', subject: 'Subject' }));
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       // @ts-expect-error - no action
       const event: Event = {
@@ -1771,7 +1771,7 @@ describe('Novu Client', () => {
         });
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -1808,7 +1808,7 @@ describe('Novu Client', () => {
         );
       });
 
-      client.addWorkflows([newWorkflow]);
+      await client.addWorkflows([newWorkflow]);
 
       const event: Event = {
         action: PostActionEnum.EXECUTE,
@@ -1828,7 +1828,7 @@ describe('Novu Client', () => {
     it('should sanitize the step output of all channel step types by default', async () => {
       const script = `<script>alert('Hello there')</script>`;
 
-      client.addWorkflows([
+      await client.addWorkflows([
         workflow('test-workflow', async ({ step }) => {
           await step.email('send-email', async () => ({
             body: `Start of body. ${script}`,
@@ -1856,7 +1856,7 @@ describe('Novu Client', () => {
     it('should sanitize the step output of channel step types when `disableOutputSanitization: false`', async () => {
       const script = `<script>alert('Hello there')</script>`;
 
-      client.addWorkflows([
+      await client.addWorkflows([
         workflow('test-workflow', async ({ step }) => {
           await step.email(
             'send-email',
@@ -1891,7 +1891,7 @@ describe('Novu Client', () => {
       const link =
         '/pipeline/Oee4d54-ca52-4d70-86b3-cd10a67b6810/requirements?requirementId=dc25a578-ecf1-4835-9310-2236f8244bd&commentId=e259b16b-68f9-43af-b252-fce68bc7cb2f';
 
-      client.addWorkflows([
+      await client.addWorkflows([
         workflow('test-workflow', async ({ step }) => {
           await step.inApp(
             'send-inapp',
@@ -1927,7 +1927,7 @@ describe('Novu Client', () => {
     it('should not sanitize the step result of custom step type', async () => {
       const script = `<script>alert('Hello there')</a>`;
 
-      client.addWorkflows([
+      await client.addWorkflows([
         workflow('test-workflow', async ({ step }) => {
           await step.custom(
             'send-email',
@@ -1981,7 +1981,7 @@ describe('Novu Client', () => {
 
       const newWorkflow = workflow('setup-workflow', workflowExecuteFunc);
 
-      getCodeClientInstance.addWorkflows([newWorkflow]);
+      await getCodeClientInstance.addWorkflows([newWorkflow]);
     });
 
     it('should throw an error when workflow ID is not found', () => {
@@ -1991,7 +1991,7 @@ describe('Novu Client', () => {
     it('should throw an error when step ID is provided but not found in the workflow', async () => {
       const newWorkflow = workflow('test-workflow', workflowExecuteFunc);
 
-      getCodeClientInstance.addWorkflows([newWorkflow]);
+      await getCodeClientInstance.addWorkflows([newWorkflow]);
 
       expect(() => getCodeClientInstance.getCode('test-workflow', 'non-existent-step')).toThrow(StepNotFoundError);
     });
diff --git a/packages/framework/src/client.ts b/packages/framework/src/client.ts
index ebd0ce6a4a4..0fbc999bb18 100644
--- a/packages/framework/src/client.ts
+++ b/packages/framework/src/client.ts
@@ -13,7 +13,6 @@ import {
   ProviderNotFoundError,
   StepControlCompilationFailedError,
   StepNotFoundError,
-  WorkflowAlreadyExistsError,
   WorkflowNotFoundError,
   StepExecutionFailedError,
   isFrameworkError,
@@ -47,6 +46,7 @@ import {
 import { validateData } from './validators';
 
 import { mockSchema } from './jsonSchemaFaker';
+import { prettyPrintDiscovery } from './resources/workflow/pretty-print-discovery';
 
 function isRuntimeInDevelopment() {
   return ['development', undefined].includes(process.env.NODE_ENV);
@@ -95,12 +95,14 @@ export class Client {
     return builtConfiguration;
   }
 
-  public addWorkflows(workflows: Array<Workflow>) {
+  public async addWorkflows(workflows: Array<Workflow>): Promise<void> {
     for (const workflow of workflows) {
-      if (this.discoveredWorkflows.some((existing) => existing.workflowId === workflow.definition.workflowId)) {
-        throw new WorkflowAlreadyExistsError(workflow.definition.workflowId);
+      if (this.discoveredWorkflows.some((existing) => existing.workflowId === workflow.id)) {
+        return;
       } else {
-        this.discoveredWorkflows.push(workflow.definition);
+        const definition = await workflow.discover();
+        prettyPrintDiscovery(definition);
+        this.discoveredWorkflows.push(definition);
       }
     }
   }
diff --git a/packages/framework/src/client.validation.test.ts b/packages/framework/src/client.validation.test.ts
index 141e1234a62..b3444d0c7c5 100644
--- a/packages/framework/src/client.validation.test.ts
+++ b/packages/framework/src/client.validation.test.ts
@@ -111,7 +111,7 @@ describe('validation', () => {
     });
 
     it('should transform a zod schema to a json schema during discovery', async () => {
-      client.addWorkflows([
+      await client.addWorkflows([
         workflow('zod-validation', async ({ step }) => {
           await step.email(
             'zod-validation',
@@ -145,7 +145,7 @@ describe('validation', () => {
     });
 
     it('should throw an error if a property is missing', async () => {
-      client.addWorkflows([
+      await client.addWorkflows([
         workflow('zod-validation', async ({ step }) => {
           await step.email(
             'test-email',
@@ -290,7 +290,7 @@ describe('validation', () => {
     });
 
     it('should transform a JSON schema to a valid schema during discovery', async () => {
-      client.addWorkflows([
+      await client.addWorkflows([
         workflow('json-schema-validation', async ({ step }) => {
           await step.email(
             'json-schema-validation',
@@ -324,7 +324,7 @@ describe('validation', () => {
     });
 
     it('should throw an error if a property is missing', async () => {
-      client.addWorkflows([
+      await client.addWorkflows([
         workflow('json-schema-validation', async ({ step }) => {
           await step.email(
             'test-email',
diff --git a/packages/framework/src/handler.ts b/packages/framework/src/handler.ts
index 63ee99e3afa..2e71b85d822 100644
--- a/packages/framework/src/handler.ts
+++ b/packages/framework/src/handler.ts
@@ -68,11 +68,12 @@ export class NovuRequestHandler<Input extends any[] = any[], Output = any> {
   public readonly client: Client;
   private readonly hmacEnabled: boolean;
   private readonly http;
+  private readonly workflows: Array<Workflow>;
 
   constructor(options: INovuRequestHandlerOptions<Input, Output>) {
     this.handler = options.handler;
     this.client = options.client ? options.client : new Client();
-    this.client.addWorkflows(options.workflows);
+    this.workflows = options.workflows;
     this.http = initApiClient(this.client.secretKey, this.client.apiUrl);
     this.frameworkName = options.frameworkName;
     this.hmacEnabled = this.client.strictAuthentication;
@@ -80,6 +81,7 @@ export class NovuRequestHandler<Input extends any[] = any[], Output = any> {
 
   public createHandler(): (...args: Input) => Promise<Output> {
     return async (...args: Input) => {
+      await this.client.addWorkflows(this.workflows);
       const actions = await this.handler(...args);
       const actionResponse = await this.handleAction({
         actions,
diff --git a/packages/framework/src/resources/workflow/discover-action-step-factory.ts b/packages/framework/src/resources/workflow/discover-action-step-factory.ts
index 50ccce64748..8b7d7d4fcca 100644
--- a/packages/framework/src/resources/workflow/discover-action-step-factory.ts
+++ b/packages/framework/src/resources/workflow/discover-action-step-factory.ts
@@ -4,30 +4,30 @@ import type { Awaitable, DiscoverWorkflowOutput, Schema, ActionStep } from '../.
 import { transformSchema } from '../../validators';
 import { discoverStep } from './discover-step';
 
-export function discoverActionStepFactory(
+export async function discoverActionStepFactory(
   targetWorkflow: DiscoverWorkflowOutput,
   type: ActionStepEnum,
   outputSchema: Schema,
   resultSchema: Schema
   // TODO: fix typing for `resolve` to use generic typings
   // eslint-disable-next-line @typescript-eslint/no-explicit-any
-): ActionStep<any, any> {
+): Promise<ActionStep<any, any>> {
   return async (stepId, resolve, options = {}) => {
     const controlSchema = options?.controlSchema || emptySchema;
 
-    discoverStep(targetWorkflow, stepId, {
+    await discoverStep(targetWorkflow, stepId, {
       stepId,
       type,
       controls: {
-        schema: transformSchema(controlSchema),
+        schema: await transformSchema(controlSchema),
         unknownSchema: controlSchema,
       },
       outputs: {
-        schema: transformSchema(outputSchema),
+        schema: await transformSchema(outputSchema),
         unknownSchema: outputSchema,
       },
       results: {
-        schema: transformSchema(resultSchema),
+        schema: await transformSchema(resultSchema),
         unknownSchema: resultSchema,
       },
       resolve: resolve as (controls: Record<string, unknown>) => Awaitable<Record<string, unknown>>,
diff --git a/packages/framework/src/resources/workflow/discover-channel-step-factory.ts b/packages/framework/src/resources/workflow/discover-channel-step-factory.ts
index b1718a93996..6b3fb0e5656 100644
--- a/packages/framework/src/resources/workflow/discover-channel-step-factory.ts
+++ b/packages/framework/src/resources/workflow/discover-channel-step-factory.ts
@@ -5,13 +5,13 @@ import { transformSchema } from '../../validators';
 import { discoverProviders } from './discover-providers';
 import { discoverStep } from './discover-step';
 
-export function discoverChannelStepFactory(
+export async function discoverChannelStepFactory(
   targetWorkflow: DiscoverWorkflowOutput,
   type: ChannelStepEnum,
   outputSchema: Schema,
   resultSchema: Schema
   // eslint-disable-next-line @typescript-eslint/no-explicit-any
-): ChannelStep<ChannelStepEnum, any, any> {
+): Promise<ChannelStep<ChannelStepEnum, any, any>> {
   return async (stepId, resolve, options = {}) => {
     const controlSchema = options?.controlSchema || emptySchema;
 
@@ -19,15 +19,15 @@ export function discoverChannelStepFactory(
       stepId,
       type,
       controls: {
-        schema: transformSchema(controlSchema),
+        schema: await transformSchema(controlSchema),
         unknownSchema: controlSchema,
       },
       outputs: {
-        schema: transformSchema(outputSchema),
+        schema: await transformSchema(outputSchema),
         unknownSchema: outputSchema,
       },
       results: {
-        schema: transformSchema(resultSchema),
+        schema: await transformSchema(resultSchema),
         unknownSchema: resultSchema,
       },
       resolve: resolve as (controls: Record<string, unknown>) => Awaitable<Record<string, unknown>>,
@@ -36,7 +36,7 @@ export function discoverChannelStepFactory(
       providers: [],
     };
 
-    discoverStep(targetWorkflow, stepId, step);
+    await discoverStep(targetWorkflow, stepId, step);
 
     if (Object.keys(options.providers || {}).length > 0) {
       discoverProviders(step, type as ChannelStepEnum, options.providers || {});
diff --git a/packages/framework/src/resources/workflow/discover-custom-step-factory.ts b/packages/framework/src/resources/workflow/discover-custom-step-factory.ts
index faa8201a95d..66a6d5ebf36 100644
--- a/packages/framework/src/resources/workflow/discover-custom-step-factory.ts
+++ b/packages/framework/src/resources/workflow/discover-custom-step-factory.ts
@@ -3,24 +3,27 @@ import type { Awaitable, CustomStep, DiscoverWorkflowOutput, StepType, StepOutpu
 import { transformSchema } from '../../validators';
 import { discoverStep } from './discover-step';
 
-export function discoverCustomStepFactory(targetWorkflow: DiscoverWorkflowOutput, type: StepType): CustomStep {
+export async function discoverCustomStepFactory(
+  targetWorkflow: DiscoverWorkflowOutput,
+  type: StepType
+): Promise<CustomStep> {
   return async (stepId, resolve, options = {}) => {
     const controlSchema = options?.controlSchema || emptySchema;
     const outputSchema = options?.outputSchema || emptySchema;
 
-    discoverStep(targetWorkflow, stepId, {
+    await discoverStep(targetWorkflow, stepId, {
       stepId,
       type,
       controls: {
-        schema: transformSchema(controlSchema),
+        schema: await transformSchema(controlSchema),
         unknownSchema: controlSchema,
       },
       outputs: {
-        schema: transformSchema(outputSchema),
+        schema: await transformSchema(outputSchema),
         unknownSchema: outputSchema,
       },
       results: {
-        schema: transformSchema(outputSchema),
+        schema: await transformSchema(outputSchema),
         unknownSchema: outputSchema,
       },
       resolve: resolve as (controls: Record<string, unknown>) => Awaitable<Record<string, unknown>>,
diff --git a/packages/framework/src/resources/workflow/discover-providers.ts b/packages/framework/src/resources/workflow/discover-providers.ts
index 14fd45cf66e..672c0766474 100644
--- a/packages/framework/src/resources/workflow/discover-providers.ts
+++ b/packages/framework/src/resources/workflow/discover-providers.ts
@@ -4,7 +4,7 @@ import type { Awaitable, DiscoverStepOutput } from '../../types';
 import { WithPassthrough } from '../../types/provider.types';
 import { transformSchema } from '../../validators';
 
-export function discoverProviders(
+export async function discoverProviders(
   step: DiscoverStepOutput,
   channelType: ChannelStepEnum,
   providers: Record<
@@ -17,10 +17,10 @@ export function discoverProviders(
       outputs: Record<string, unknown>;
     }) => Awaitable<WithPassthrough<Record<string, unknown>>>
   >
-): void {
+): Promise<void> {
   const channelSchemas = providerSchemas[channelType];
 
-  Object.entries(providers).forEach(([type, resolve]) => {
+  Object.entries(providers).forEach(async ([type, resolve]) => {
     // eslint-disable-next-line multiline-comment-style
     // TODO: fix the typing for `type` to use the keyof providerSchema[channelType]
     // @ts-expect-error - Element implicitly has an 'any' type because expression of type 'string' can't be used to index type
@@ -30,7 +30,7 @@ export function discoverProviders(
       code: resolve.toString(),
       resolve,
       outputs: {
-        schema: transformSchema(schemas.output),
+        schema: await transformSchema(schemas.output),
         unknownSchema: schemas.output,
       },
     });
diff --git a/packages/framework/src/resources/workflow/discover-step.ts b/packages/framework/src/resources/workflow/discover-step.ts
index 161a61b25d1..032a755ee61 100644
--- a/packages/framework/src/resources/workflow/discover-step.ts
+++ b/packages/framework/src/resources/workflow/discover-step.ts
@@ -1,7 +1,11 @@
 import { StepAlreadyExistsError } from '../../errors';
 import type { DiscoverStepOutput, DiscoverWorkflowOutput } from '../../types';
 
-export function discoverStep(targetWorkflow: DiscoverWorkflowOutput, stepId: string, step: DiscoverStepOutput): void {
+export async function discoverStep(
+  targetWorkflow: DiscoverWorkflowOutput,
+  stepId: string,
+  step: DiscoverStepOutput
+): Promise<void> {
   if (targetWorkflow.steps.some((workflowStep) => workflowStep.stepId === stepId)) {
     throw new StepAlreadyExistsError(stepId);
   } else {
diff --git a/packages/framework/src/resources/workflow/workflow.resource.ts b/packages/framework/src/resources/workflow/workflow.resource.ts
index 51dce4d6171..c6d868d6558 100644
--- a/packages/framework/src/resources/workflow/workflow.resource.ts
+++ b/packages/framework/src/resources/workflow/workflow.resource.ts
@@ -18,7 +18,6 @@ import { discoverActionStepFactory } from './discover-action-step-factory';
 import { discoverChannelStepFactory } from './discover-channel-step-factory';
 import { discoverCustomStepFactory } from './discover-custom-step-factory';
 import { mapPreferences } from './map-preferences';
-import { prettyPrintDiscovery } from './pretty-print-discovery';
 
 /**
  * Define a new notification workflow.
@@ -77,81 +76,84 @@ export function workflow<
     };
   };
 
-  const newWorkflow: DiscoverWorkflowOutput = {
-    workflowId,
-    steps: [],
-    code: execute.toString(),
-    payload: {
-      schema: transformSchema(options.payloadSchema || emptySchema),
-      unknownSchema: options.payloadSchema || emptySchema,
-    },
-    controls: {
-      schema: transformSchema(options.controlSchema || emptySchema),
-      unknownSchema: options.controlSchema || emptySchema,
-    },
-    tags: options.tags || [],
-    preferences: mapPreferences(options.preferences),
-    name: options.name,
-    description: options.description,
-    execute: execute as Execute<Record<string, unknown>, Record<string, unknown>>,
-  };
+  const discover = async (): Promise<DiscoverWorkflowOutput> => {
+    const newWorkflow: DiscoverWorkflowOutput = {
+      workflowId,
+      steps: [],
+      code: execute.toString(),
+      payload: {
+        schema: await transformSchema(options.payloadSchema || emptySchema),
+        unknownSchema: options.payloadSchema || emptySchema,
+      },
+      controls: {
+        schema: await transformSchema(options.controlSchema || emptySchema),
+        unknownSchema: options.controlSchema || emptySchema,
+      },
+      tags: options.tags || [],
+      preferences: mapPreferences(options.preferences),
+      name: options.name,
+      description: options.description,
+      execute: execute as Execute<Record<string, unknown>, Record<string, unknown>>,
+    };
+
+    await execute({
+      payload: {} as T_PayloadValidated,
+      subscriber: {},
+      environment: {},
+      controls: {} as T_Controls,
+      step: {
+        push: await discoverChannelStepFactory(
+          newWorkflow,
+          ChannelStepEnum.PUSH,
+          channelStepSchemas.push.output,
+          channelStepSchemas.push.result
+        ),
+        chat: await discoverChannelStepFactory(
+          newWorkflow,
+          ChannelStepEnum.CHAT,
+          channelStepSchemas.chat.output,
+          channelStepSchemas.chat.result
+        ),
+        email: await discoverChannelStepFactory(
+          newWorkflow,
+          ChannelStepEnum.EMAIL,
+          channelStepSchemas.email.output,
+          channelStepSchemas.email.result
+        ),
+        sms: await discoverChannelStepFactory(
+          newWorkflow,
+          ChannelStepEnum.SMS,
+          channelStepSchemas.sms.output,
+          channelStepSchemas.sms.result
+        ),
+        inApp: await discoverChannelStepFactory(
+          newWorkflow,
+          ChannelStepEnum.IN_APP,
+          channelStepSchemas.in_app.output,
+          channelStepSchemas.in_app.result
+        ),
+        digest: await discoverActionStepFactory(
+          newWorkflow,
+          ActionStepEnum.DIGEST,
+          digestActionSchemas.output,
+          digestActionSchemas.result
+        ),
+        delay: await discoverActionStepFactory(
+          newWorkflow,
+          ActionStepEnum.DELAY,
+          delayActionSchemas.output,
+          delayActionSchemas.result
+        ),
+        custom: await discoverCustomStepFactory(newWorkflow, ActionStepEnum.CUSTOM),
+      } as never,
+    });
 
-  execute({
-    payload: {} as T_PayloadValidated,
-    subscriber: {},
-    environment: {},
-    controls: {} as T_Controls,
-    step: {
-      push: discoverChannelStepFactory(
-        newWorkflow,
-        ChannelStepEnum.PUSH,
-        channelStepSchemas.push.output,
-        channelStepSchemas.push.result
-      ),
-      chat: discoverChannelStepFactory(
-        newWorkflow,
-        ChannelStepEnum.CHAT,
-        channelStepSchemas.chat.output,
-        channelStepSchemas.chat.result
-      ),
-      email: discoverChannelStepFactory(
-        newWorkflow,
-        ChannelStepEnum.EMAIL,
-        channelStepSchemas.email.output,
-        channelStepSchemas.email.result
-      ),
-      sms: discoverChannelStepFactory(
-        newWorkflow,
-        ChannelStepEnum.SMS,
-        channelStepSchemas.sms.output,
-        channelStepSchemas.sms.result
-      ),
-      inApp: discoverChannelStepFactory(
-        newWorkflow,
-        ChannelStepEnum.IN_APP,
-        channelStepSchemas.in_app.output,
-        channelStepSchemas.in_app.result
-      ),
-      digest: discoverActionStepFactory(
-        newWorkflow,
-        ActionStepEnum.DIGEST,
-        digestActionSchemas.output,
-        digestActionSchemas.result
-      ),
-      delay: discoverActionStepFactory(
-        newWorkflow,
-        ActionStepEnum.DELAY,
-        delayActionSchemas.output,
-        delayActionSchemas.result
-      ),
-      custom: discoverCustomStepFactory(newWorkflow, ActionStepEnum.CUSTOM),
-    } as never,
-  }).then(() => {
-    prettyPrintDiscovery(newWorkflow);
-  });
+    return newWorkflow;
+  };
 
   return {
+    id: workflowId,
     trigger,
-    definition: newWorkflow,
+    discover,
   };
 }
diff --git a/packages/framework/src/resources/workflow/workflow.test.ts b/packages/framework/src/resources/workflow/workflow.test.ts
index 396e2977bcf..cf6b947c848 100644
--- a/packages/framework/src/resources/workflow/workflow.test.ts
+++ b/packages/framework/src/resources/workflow/workflow.test.ts
@@ -99,7 +99,7 @@ describe('workflow function', () => {
   });
 
   it('should include the defined preferences', async () => {
-    const { definition } = workflow(
+    const { discover } = workflow(
       'setup-workflow',
       async ({ step }) => {
         await step.email('send-email', async () => ({
@@ -116,6 +116,8 @@ describe('workflow function', () => {
       }
     );
 
+    const definition = await discover();
+
     expect(definition.preferences).to.deep.equal({
       channels: {
         email: { enabled: true },
@@ -124,7 +126,7 @@ describe('workflow function', () => {
   });
 
   it('should include the defined name', async () => {
-    const { definition } = workflow(
+    const { discover } = workflow(
       'workflow-with-name',
       async ({ step }) => {
         await step.email('send-email', async () => ({
@@ -137,11 +139,13 @@ describe('workflow function', () => {
       }
     );
 
+    const definition = await discover();
+
     expect(definition.name).to.equal('My Workflow');
   });
 
   it('should include the defined description', async () => {
-    const { definition } = workflow(
+    const { discover } = workflow(
       'workflow-with-description',
       async ({ step }) => {
         await step.email('send-email', async () => ({
@@ -154,6 +158,8 @@ describe('workflow function', () => {
       }
     );
 
+    const definition = await discover();
+
     expect(definition.description).to.equal('My Workflow Description');
   });
 
diff --git a/packages/framework/src/types/discover.types.ts b/packages/framework/src/types/discover.types.ts
index dae568a7cfa..0af4e50ee0c 100644
--- a/packages/framework/src/types/discover.types.ts
+++ b/packages/framework/src/types/discover.types.ts
@@ -67,10 +67,25 @@ export type DiscoverWorkflowOutput = {
 
 // eslint-disable-next-line @typescript-eslint/no-explicit-any
 export type Workflow<T_Payload = any> = {
+  /**
+   * The unique identifier of the workflow.
+   */
+  id: string;
+  /**
+   * Trigger an event for this workflow with a strongly typed and validated `payload`, derived from the `payloadSchema`.
+   *
+   * @param event - The event to trigger
+   * @returns `EventTriggerResult` - The result of the event trigger
+   */
   trigger: (
     event: Prettify<Omit<EventTriggerParams<T_Payload>, 'workflowId' | 'bridgeUrl' | 'controls'>>
   ) => Promise<EventTriggerResult>;
-  definition: DiscoverWorkflowOutput;
+  /**
+   * Discover the workflow definition.
+   *
+   * @returns `DiscoverWorkflowOutput` - The workflow definition
+   */
+  discover: () => Promise<DiscoverWorkflowOutput>;
 };
 
 export type DiscoverOutput = {
diff --git a/packages/framework/src/types/validator.types.ts b/packages/framework/src/types/validator.types.ts
index 1f9225645b2..36826f8bf2b 100644
--- a/packages/framework/src/types/validator.types.ts
+++ b/packages/framework/src/types/validator.types.ts
@@ -29,5 +29,5 @@ export interface Validator<T_Schema extends Schema = Schema> {
     schema: T_Schema
   ) => Promise<ValidateResult<T_Validated>>;
   canHandle: (schema: Schema) => schema is T_Schema;
-  transformToJsonSchema: (schema: T_Schema) => JsonSchema;
+  transformToJsonSchema: (schema: T_Schema) => Promise<JsonSchema>;
 }
diff --git a/packages/framework/src/validators/base.validator.ts b/packages/framework/src/validators/base.validator.ts
index 4ac5e959e60..3a7f170a634 100644
--- a/packages/framework/src/validators/base.validator.ts
+++ b/packages/framework/src/validators/base.validator.ts
@@ -23,7 +23,7 @@ export const validateData = async <
   throw new Error('Invalid schema');
 };
 
-export const transformSchema = (schema: Schema): JsonSchema => {
+export const transformSchema = async (schema: Schema): Promise<JsonSchema> => {
   if (zodValidator.canHandle(schema)) {
     return zodValidator.transformToJsonSchema(schema);
   } else if (jsonSchemaValidator.canHandle(schema)) {
diff --git a/packages/framework/src/validators/json-schema.validator.ts b/packages/framework/src/validators/json-schema.validator.ts
index 51bf08234c2..2a5446d7a9a 100644
--- a/packages/framework/src/validators/json-schema.validator.ts
+++ b/packages/framework/src/validators/json-schema.validator.ts
@@ -68,7 +68,7 @@ export class JsonSchemaValidator implements Validator<JsonSchema> {
     }
   }
 
-  transformToJsonSchema(schema: JsonSchema): JsonSchema {
+  async transformToJsonSchema(schema: JsonSchema): Promise<JsonSchema> {
     return schema;
   }
 }
diff --git a/packages/framework/src/validators/validator.test.ts b/packages/framework/src/validators/validator.test.ts
index 62ae56876e7..c52531a19e1 100644
--- a/packages/framework/src/validators/validator.test.ts
+++ b/packages/framework/src/validators/validator.test.ts
@@ -520,19 +520,19 @@ describe('validators', () => {
         testCases
           .filter((testCase) => testCase.schemas[schema] !== null)
           .forEach((testCase) => {
-            it(testCase.title, () => {
-              const result = transformSchema(testCase.schemas[schema] as Schema);
+            it(testCase.title, async () => {
+              const result = await transformSchema(testCase.schemas[schema] as Schema);
               expect(result).deep.contain(testCase.result);
             });
           });
       });
     });
 
-    it('should throw an error for invalid schema', () => {
+    it('should throw an error for invalid schema', async () => {
       const schema = { invalidKey: 'test' } as const;
 
       // @ts-expect-error - we are testing the type guard
-      expect(() => transformSchema(schema)).toThrow('Invalid schema');
+      await expect(transformSchema(schema)).rejects.toThrow('Invalid schema');
     });
   });
 });
diff --git a/packages/framework/src/validators/zod.validator.ts b/packages/framework/src/validators/zod.validator.ts
index e6eb413a372..5d383111cb0 100644
--- a/packages/framework/src/validators/zod.validator.ts
+++ b/packages/framework/src/validators/zod.validator.ts
@@ -27,10 +27,9 @@ export class ZodValidator implements Validator<ZodSchema> {
     }
   }
 
-  transformToJsonSchema(schema: ZodSchema): JsonSchema {
+  async transformToJsonSchema(schema: ZodSchema): Promise<JsonSchema> {
     try {
-      // eslint-disable-next-line global-require
-      const { zodToJsonSchema } = require('zod-to-json-schema') as typeof import('zod-to-json-schema');
+      const { zodToJsonSchema } = await import('zod-to-json-schema');
 
       // @ts-expect-error - zod-to-json-schema is not using JSONSchema7
       return zodToJsonSchema(schema);