Skip to content

Commit 7ee2ffd

Browse files
committed
debug: add logs to trace mediawiki workflow executation
1 parent ec726af commit 7ee2ffd

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

src/services/module.service.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -151,8 +151,8 @@ const handleHivemindMediaWikiCase = async (platform: any) => {
151151
if (isActivated === true) {
152152
console.log('Platform is activated, checking for existing workflow ID:', existingWorkflowId);
153153
if (!existingWorkflowId) {
154-
console.log('No existing workflow ID found, executing new workflow for platform:', platform.platform);
155-
const workflowId = await temporalMediaWiki.executeWorkflow(platform.platform);
154+
console.log('No existing workflow ID found, executing new workflow for platform:', platformDoc.id);
155+
const workflowId = await temporalMediaWiki.executeWorkflow(platformDoc.id);
156156
console.log('New workflow ID created:', workflowId);
157157
platformDoc.set('metadata.workflowId', workflowId);
158158
await platformDoc.save();

src/services/temporal/mediaWiki.service.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,11 +11,13 @@ const logger = parentLogger.child({ module: 'MediaWikiTemporalService' });
1111

1212
class TemporalMediaWikiService extends TemporalCoreService {
1313
public async executeWorkflow(platformId: Types.ObjectId) {
14+
console.log('Executing MediaWiki workflow for platform ID:', platformId);
1415
const client: Client = await this.getClient();
1516
const payload = {
1617
platform_id: platformId,
1718
};
1819
try {
20+
console.log('Triggering MediaWiki workflow with payload:', payload);
1921
const workflowHandle = await client.workflow.execute('MediaWikiETLWorkflow', {
2022
taskQueue: queues.TEMPORAL_QUEUE_PYTHON_HEAVY,
2123
args: [payload],

0 commit comments

Comments
 (0)