How to Celebrate Wrike Milestones in Slack with Pipedream

pipedream.com > Workflows > New Workflow

Create a new Pipedream workflow

Go to pipedream.com and sign in. Click 'New Workflow' in the top-right corner of the dashboard. You'll land on a blank canvas with a prompt to select a trigger. Name your workflow something like 'Wrike Milestone → Slack Celebration' using the pencil icon at the top so it's easy to find later.

1. 1Click 'New Workflow' in the top-right
2. 2Click the pencil icon next to 'My Workflow' and rename it
3. 3Click 'Add Trigger' in the center of the canvas

Trigger > Search Apps > Wrike > Task Status Changed

Set the trigger to Wrike — Task Completed

In the trigger search box, type 'Wrike' and select it from the app list. Choose the trigger event 'Task Status Changed' — this is the correct trigger because Wrike's API emits a webhook event when task status is updated, which covers milestone completion. You'll connect your Wrike account via Connected Accounts; click 'Connect Account' and authorize with OAuth.

1. 1Type 'Wrike' in the trigger search box
2. 2Select 'Wrike' from the app list
3. 3Choose 'Task Status Changed' as the trigger event
4. 4Click 'Connect Account' and complete the Wrike OAuth flow
5. 5Click 'Save and continue'

Wrike > Account Settings > Apps & Integrations > Webhooks > Create Webhook

Register the webhook inside Wrike

Pipedream generates a unique webhook URL for your trigger. Copy that URL. In a separate tab, open Wrike and navigate to Apps & Integrations > Webhooks. Click 'Create Webhook', paste the Pipedream URL, and set the event filter to 'Task status changed'. Optionally scope it to a specific Folder or Project to avoid noise from unrelated tasks.

1. 1Copy the webhook URL from the Pipedream trigger step
2. 2Open Wrike in a new tab and go to Account Settings
3. 3Navigate to Apps & Integrations > Webhooks
4. 4Click 'Create Webhook' and paste the URL
5. 5Set the scope to your target project folder and save

Pipedream > Trigger Step > Event Inspection Panel

Test the trigger and inspect the payload

In Wrike, open a test task and change its status to 'Completed'. Return to Pipedream and click 'Refresh' on the trigger step. You should see a raw JSON payload appear. Expand it and find the fields you'll need: task ID, task title, project ID, assignee ID, and completion date. Note the exact key paths — you'll reference these in the next step.

1. 1Complete a test task in Wrike
2. 2Click 'Refresh' in the Pipedream trigger step
3. 3Expand the event payload in the inspection panel
4. 4Locate and note the path to task title, assignee, and project name

Workflow Canvas > + > Built-in > Filter

Add a filter step to check milestone status

Click '+' below the trigger to add a new step. Choose 'Filter' from the built-in Pipedream helpers. Configure it to continue only when steps.trigger.event.status === 'Completed' AND the task has a milestone flag. In Wrike's API payload, milestones are identified by importance: 'high' or by a custom field — check your test payload to confirm which field your team uses to designate milestones.

1. 1Click '+' below the trigger step
2. 2Select 'Filter' from Pipedream built-ins
3. 3Set condition: steps.trigger.event.status equals Completed
4. 4Add second condition: steps.trigger.event.importance equals high (or your milestone custom field)
5. 5Set filter behavior to 'End workflow execution' if conditions are not met

Workflow Canvas > + > Node.js Code Step

Resolve assignee name via Wrike API

Add a new step and select 'Node.js code'. This step calls the Wrike API to fetch the user's display name from their user ID. Use steps.trigger.event.responsibleIds[0] as the ID to look up. Store the result as assigneeName for use in the Slack message. This prevents the celebration message from showing a raw ID like KUAK7HHHH instead of 'Sarah Chen'.

1. 1Click '+' below the filter step
2. 2Select 'Run Node.js code'
3. 3Paste the resolver code from the Pro Tip section below
4. 4Click 'Test' to confirm the step returns a name string

This single Node.js step handles three things at once: resolves the Wrike assignee ID to a display name, builds the full Slack Block Kit payload, and exports both for downstream steps. Paste this into a single Node.js code step between your filter and the Slack send step. Replace `process.env.WRIKE_API_TOKEN` with your Pipedream environment variable name.

import axios from 'axios';
export default defineComponent({
  async run({ steps, $ }) {

import axios from 'axios';

export default defineComponent({
  async run({ steps, $ }) {
    const event = steps.trigger.event;
    const taskId = event.taskId;
    const taskTitle = event.title;
    const completedDate = event.completedDate
      ? new Date(event.completedDate).toLocaleDateString('en-US', { month: 'long', day: 'numeric', year: 'numeric' })
      : 'Today';
    const wrikeTaskUrl = `https://www.wrike.com/open.htm?id=${taskId}`;

    // Resolve assignee ID to display name
    let assigneeName = 'The Team';
    const assigneeId = event.responsibleIds?.[0];
    if (assigneeId) {
      try {
        const userRes = await axios.get(
          `https://www.wrike.com/api/v4/users/${assigneeId}`,
          { headers: { Authorization: `Bearer ${process.env.WRIKE_API_TOKEN}` } }
        );
        const profile = userRes.data?.data?.[0];
        assigneeName = profile ? `${profile.firstName} ${profile.lastName}` : 'The Team';
      } catch (err) {
        console.error(`Failed to resolve assignee ${assigneeId}: ${err.message}`);
      }
    }

    // Resolve parent folder name
    let projectName = 'Unknown Project';
    const folderId = event.parentIds?.[0];
    if (folderId) {
      try {
        const folderRes = await axios.get(
          `https://www.wrike.com/api/v4/folders/${folderId}`,
          { headers: { Authorization: `Bearer ${process.env.WRIKE_API_TOKEN}` } }
        );
        projectName = folderRes.data?.data?.[0]?.title || 'Unknown Project';
      } catch (err) {
        console.error(`Failed to resolve folder ${folderId}: ${err.message}`);
      }
    }

    // Build Slack Block Kit payload
    const slackPayload = {
      text: `🎉 Milestone complete: ${taskTitle}`,
      blocks: [
        {
          type: 'header',
          text: { type: 'plain_text', text: '🎉 Milestone Achieved!', emoji: true }
        },
        {
          type: 'section',
          text: {
            type: 'mrkdwn',
            text: `*${taskTitle}* is done!\n👤 Completed by: ${assigneeName}\n📁 Project: ${projectName}\n📅 ${completedDate}`
          }
        },
        {
          type: 'actions',
          elements: [
            {
              type: 'button',
              text: { type: 'plain_text', text: 'View in Wrike', emoji: true },
              url: wrikeTaskUrl,
              style: 'primary'
            }
          ]
        }
      ]
    };

    $.export('assigneeName', assigneeName);
    $.export('projectName', projectName);
    $.export('slackPayload', slackPayload);
  }
});

Workflow Canvas > + > Node.js Code Step

Format the Slack celebration message

Add another Node.js code step to build the Slack Block Kit payload. Use Block Kit instead of plain text — it renders better on desktop and mobile, supports emoji headers, and lets you embed the direct Wrike task link as a button. Pull steps.trigger.event.title, steps.resolve_assignee.assigneeName, and construct the Wrike task URL as https://www.wrike.com/open.htm?id=${steps.trigger.event.taskId}.

1. 1Click '+' to add another Node.js step
2. 2Build the Block Kit JSON object using the template in the Pro Tip section
3. 3Interpolate task title, assignee name, project name, and task URL
4. 4Export the payload as $.export('slackPayload', blocks)
5. 5Test the step and confirm the output is valid JSON

Workflow Canvas > + > Slack > Send Message

Connect Slack and post to the channel

Add a new step and search for 'Slack'. Select the action 'Send Message'. Connect your Slack workspace via Connected Accounts — this requires the chat:write and chat:write.public OAuth scopes. Set the Channel field to your target channel (e.g. #project-wins). In the Blocks field, reference {{steps.format_message.slackPayload}} and set the Text field to a plain fallback like 🎉 Milestone completed: {{steps.trigger.event.title}}.

1. 1Click '+' and search for 'Slack'
2. 2Select 'Send Message (Advanced)' to access the Blocks field
3. 3Click 'Connect Account' and authorize your Slack workspace
4. 4Set Channel to your target Slack channel name or ID
5. 5Set Blocks to reference your formatted payload from the previous step
6. 6Set Text to the plain fallback string

Workflow Canvas > + > Node.js Code Step

Add error handling for failed deliveries

Add a final Node.js step with a try/catch that checks the Slack API response for ok: false. If Slack returns an error (e.g. channel_not_found or not_in_channel), use $.flow.exit() to stop cleanly and log the error with console.error(). This prevents the workflow from silently failing and gives you visibility in Pipedream's event logs.

1. 1Add a Node.js step after the Slack send step
2. 2Wrap logic in try/catch
3. 3Check steps.send_slack_message.$return_value.ok equals true
4. 4Call console.error() with the Slack error code if false

Pipedream Workflow Canvas > Deploy Button (top-right)

Deploy and set workflow to Active

Click 'Deploy' in the top-right corner of the Pipedream canvas. The workflow status changes from 'Development' to 'Active'. From this point, every qualifying Wrike milestone completion will trigger the full workflow in production. Run one final end-to-end test by completing a real milestone in Wrike and confirming the Slack message appears within 10 seconds.

1. 1Click 'Deploy' in the top-right corner
2. 2Confirm the workflow status badge reads 'Active'
3. 3Complete a real milestone task in Wrike
4. 4Verify the Slack message appears in the target channel