runSingleOrganizationWorker
Function: runSingleOrganizationWorker()
runSingleOrganizationWorker(
organizationId,drizzleClient,logger):Promise<WorkerResult>
Defined in: src/workers/eventGeneration/eventGenerationPipeline.ts:139
Manually triggers the materialization process for a single, specific organization.
Parameters
organizationId
string
The ID of the organization to process.
drizzleClient
NodePgDatabase<API Docs>
The Drizzle ORM client for database access.
logger
FastifyBaseLogger
The logger for logging the process.
Returns
Promise<WorkerResult>
A promise that resolves to the result of the processing for the specified organization.