update

backend/app/models.py

@@ -1,5 +1,5 @@
 from pydantic import BaseModel, Field, field_validator
-from typing import Optional, List, Dict, Literal
+from typing import Optional, List, Dict, Literal, Any, Union
 from datetime import datetime
 
 
@@ -14,7 +14,7 @@ class PromptSaveRequest(BaseModel):
     prompts: Dict[str, str]
     products: List[str]
     linkedin_prompts: Dict[str, str] = Field(default_factory=dict)
-    sequence_plan: Optional[List[Dict]] = Field(default=None)
+    sequence_plan: Optional[Union[List[Dict], Dict[str, Any]]] = Field(default=None)
 
 
 class SequenceResponse(BaseModel):

backend/app/outreach_routes.py

@@ -156,22 +156,109 @@ def _unipile_call(method: str, path: str, payload: Optional[dict] = None) -> Tup
     return resp.status_code, data
 
 
-def _normalize_plan_steps(raw: Any) -> List[dict]:
-    if raw is None:
-        return []
-    if isinstance(raw, dict) and isinstance(raw.get("steps"), list):
-        return [x for x in raw["steps"] if isinstance(x, dict)]
-    if isinstance(raw, list):
-        return [x for x in raw if isinstance(x, dict)]
-    return []
+def load_campaign_plan_from_json(raw_plan: Optional[Any]) -> Tuple[List[dict], bool]:
+    """Parse uploaded_files.sequence_plan_json: steps list + optional parallel_tracks flag."""
+    if raw_plan is None:
+        return [], False
+    if isinstance(raw_plan, str):
+        if not raw_plan.strip():
+            return [], False
+        try:
+            parsed: Any = json.loads(raw_plan)
+        except Exception:
+            return [], False
+    else:
+        parsed = raw_plan
+    parallel = False
+    if isinstance(parsed, dict):
+        v = parsed.get("parallel_tracks")
+        if v is True or (isinstance(v, (int, float)) and int(v) == 1):
+            parallel = True
+        elif isinstance(v, str) and v.strip().lower() in ("1", "true", "yes"):
+            parallel = True
+        steps = [x for x in (parsed.get("steps") or []) if isinstance(x, dict)]
+        return steps, parallel
+    if isinstance(parsed, list):
+        return [x for x in parsed if isinstance(x, dict)], False
+    return [], False
+
+
+def _action_lane(channel: str) -> str:
+    return "gmail" if (channel or "").strip().lower() == "gmail" else "linkedin"
+
+
+def _build_ordered_actions_parallel(steps: List[dict]) -> List[dict]:
+    """Same global step_order as serial; waits only stack within each channel (LinkedIn ignores cross-email waits)."""
+    events: List[Tuple[str, Any]] = []
+    for s in steps:
+        if not isinstance(s, dict):
+            continue
+        if s.get("type") == "wait":
+            try:
+                d = int(s.get("days") if s.get("days") is not None else 1)
+            except (TypeError, ValueError):
+                d = 1
+            events.append(("wait", max(0, min(int(d), 365))))
+        elif s.get("type") == "action":
+            events.append(("action", s))
+    action_positions = [i for i, e in enumerate(events) if e[0] == "action"]
+    out: List[dict] = []
+    ord_global = 0
+    for ai in action_positions:
+        s = events[ai][1]
+        if not isinstance(s, dict):
+            continue
+        ch = (s.get("channel") or "").strip()
+        act = (s.get("action") or "").strip()
+        ref = s.get("unipile_account_ref_id")
+        try:
+            ref_i = int(ref) if ref is not None and str(ref).strip() != "" else None
+        except (TypeError, ValueError):
+            ref_i = None
+        lane = _action_lane(ch)
+        ord_global += 1
+        wd = 0
+        prev_pos: Optional[int] = None
+        for q in reversed([x for x in action_positions if x < ai]):
+            sq = events[q][1]
+            if not isinstance(sq, dict):
+                continue
+            lq = _action_lane((sq.get("channel") or "").strip())
+            if lq == lane:
+                prev_pos = q
+                break
+        if prev_pos is None:
+            for k in range(0, ai):
+                if events[k][0] == "wait":
+                    wd += int(events[k][1])
+            if lane == "linkedin":
+                wd = 0
+        else:
+            for k in range(prev_pos + 1, ai):
+                if events[k][0] == "wait":
+                    wd += int(events[k][1])
+        out.append(
+            {
+                "order": ord_global,
+                "channel": ch,
+                "action": act,
+                "account_ref_id": ref_i,
+                "wait_days_before": int(wd),
+                "lane": lane,
+            }
+        )
+    return out
 
 
-def build_ordered_actions(steps: List[dict]) -> List[dict]:
+def build_ordered_actions(steps: List[dict], *, parallel_tracks: bool = False) -> List[dict]:
     """Flatten sequence plan to sendable actions with global step_order (matches GeneratedSequence.step_order).
 
-    ``wait_days_before`` is the sum of wizard ``wait`` steps immediately preceding this action (calendar days
-    after the previous slot completes before this slot may send).
+    ``wait_days_before`` is calendar days after the dependency anchor:
+    - Serial: after the previous step (any channel) completes.
+    - ``parallel_tracks``: per channel only — waits between Gmail and LinkedIn do not delay the other channel.
     """
+    if parallel_tracks:
+        return _build_ordered_actions_parallel(steps)
     out: List[dict] = []
     ord_global = 0
     wait_accum = 0
@@ -200,6 +287,7 @@ def build_ordered_actions(steps: List[dict]) -> List[dict]:
                 "action": act,
                 "account_ref_id": ref_i,
                 "wait_days_before": int(wait_accum),
+                "lane": _action_lane(ch),
             }
         )
         wait_accum = 0
@@ -267,6 +355,8 @@ def _wait_eligible_for_slot(
     slot: int,
     prev_rec: Optional[OutreachSendReceipt],
     now: datetime,
+    *,
+    parallel_tracks: bool = False,
 ) -> bool:
     try:
         wd = int(act.get("wait_days_before") or 0)
@@ -274,7 +364,10 @@ def _wait_eligible_for_slot(
         wd = 0
     if wd <= 0:
         return True
-    if slot <= 0:
+    use_anchor = slot <= 0
+    if parallel_tracks and prev_rec is None:
+        use_anchor = True
+    if use_anchor:
         anchor = _delivery_started_at_naive(ex) or now
         return now >= anchor + timedelta(days=wd)
     if not prev_rec or not prev_rec.created_at:
@@ -492,6 +585,8 @@ def _find_next_send(
     contacts: List[Contact],
     actions: List[dict],
     ex: FileOutreachExecution,
+    *,
+    parallel_tracks: bool = False,
 ) -> Optional[Tuple[Contact, int, dict]]:
     n_actions = len(actions)
     if not contacts or not actions:
@@ -505,19 +600,30 @@ def _find_next_send(
         for slot in range(n_actions):
             if _receipt_for(db, tenant_id, file_id, c.id, slot):
                 continue
+            act = actions[slot]
+            lane_cur = _action_lane(str(act.get("channel") or ""))
             ok = True
             prev_rec: Optional[OutreachSendReceipt] = None
             for ps in range(slot):
                 pr = _receipt_for(db, tenant_id, file_id, c.id, ps)
-                if not pr or pr.status not in ("sent", "failed", "skipped"):
-                    ok = False
-                    break
-                if ps == slot - 1:
+                act_ps = actions[ps]
+                lane_ps = _action_lane(str(act_ps.get("channel") or ""))
+                if parallel_tracks:
+                    if lane_ps != lane_cur:
+                        continue
+                    if not pr or pr.status not in ("sent", "failed", "skipped"):
+                        ok = False
+                        break
                     prev_rec = pr
+                else:
+                    if not pr or pr.status not in ("sent", "failed", "skipped"):
+                        ok = False
+                        break
+                    if ps == slot - 1:
+                        prev_rec = pr
             if not ok:
                 continue
-            act = actions[slot]
-            if not _wait_eligible_for_slot(ex, act, slot, prev_rec, now):
+            if not _wait_eligible_for_slot(ex, act, slot, prev_rec, now, parallel_tracks=parallel_tracks):
                 continue
             if act.get("channel") == "linkedin" and act.get("action") == "linkedin_dm":
                 if not _linkedin_dm_interval_eligible(c, li_h, now):
@@ -751,12 +857,13 @@ def start_campaign_execution(
 
     raw_plan = getattr(uf, "sequence_plan_json", None)
     steps: List[dict] = []
+    parallel_flag = False
     if raw_plan and str(raw_plan).strip():
         try:
-            steps = _normalize_plan_steps(json.loads(raw_plan))
+            steps, parallel_flag = load_campaign_plan_from_json(json.loads(raw_plan))
         except Exception:
-            steps = []
-    actions = build_ordered_actions(steps)
+            steps, parallel_flag = [], False
+    actions = build_ordered_actions(steps, parallel_tracks=parallel_flag)
     contacts = (
         db.query(Contact)
         .filter(
@@ -866,14 +973,15 @@ def tick_campaign_execution(
     if ex.status != "running":
         return get_campaign_execution(file_id, tc)
 
-    steps = []
+    steps: List[dict] = []
+    parallel_flag = False
     raw = getattr(uf, "sequence_plan_json", None)
     if raw and str(raw).strip():
         try:
-            steps = _normalize_plan_steps(json.loads(raw))
+            steps, parallel_flag = load_campaign_plan_from_json(json.loads(raw))
         except Exception:
-            steps = []
-    actions = build_ordered_actions(steps)
+            steps, parallel_flag = [], False
+    actions = build_ordered_actions(steps, parallel_tracks=parallel_flag)
     contacts = (
         db.query(Contact)
         .filter(
@@ -893,7 +1001,9 @@ def tick_campaign_execution(
 
     n = max(1, min(int(limit or 3), 25))
     for _ in range(n):
-        nxt = _find_next_send(db, int(tc.tenant_id), file_id, contacts, actions, ex)
+        nxt = _find_next_send(
+            db, int(tc.tenant_id), file_id, contacts, actions, ex, parallel_tracks=parallel_flag
+        )
         if not nxt:
             break
         c, slot, act = nxt

frontend/src/components/campaigns/CampaignSequenceBuilder.jsx

@@ -274,7 +274,14 @@ function ActionCard({
 /**
  * Vertical sequence builder: START → steps (+ inserts) → END with dashed spine.
  */
-export default function CampaignSequenceBuilder({ value, onChange, linkedinDefaults, mailboxDefaults }) {
+export default function CampaignSequenceBuilder({
+    value,
+    onChange,
+    parallelTracks = false,
+    onParallelTracksChange,
+    linkedinDefaults,
+    mailboxDefaults,
+}) {
     const steps = value;
     const setSteps = onChange;
     const [pickerIndex, setPickerIndex] = useState(null);
@@ -375,6 +382,28 @@ export default function CampaignSequenceBuilder({ value, onChange, linkedinDefau
                 </div>
             ) : null}
 
+            {onParallelTracksChange ? (
+                <div className="mb-4 rounded-lg border border-slate-200 bg-slate-50/90 px-3 py-2.5">
+                    <label className="flex cursor-pointer items-start gap-2.5 text-left">
+                        <input
+                            type="checkbox"
+                            className="mt-0.5 h-4 w-4 shrink-0 rounded border-slate-300 text-violet-600 focus:ring-violet-500"
+                            checked={!!parallelTracks}
+                            onChange={(e) => onParallelTracksChange(e.target.checked)}
+                        />
+                        <span>
+                            <span className="text-sm font-medium text-slate-800">Parallel Gmail and LinkedIn</span>
+                            <span className="mt-0.5 block text-xs leading-snug text-slate-600">
+                                When enabled, waits only pace steps within the same channel — LinkedIn is not held up by
+                                email delays (and vice versa). The list order is unchanged; execution uses two timelines.
+                                This is saved to the server when you click <strong className="font-semibold">Generate</strong> on the
+                                next step.
+                            </span>
+                        </span>
+                    </label>
+                </div>
+            ) : null}
+
             <div className="relative flex flex-col items-center">
                 {/* Vertical dashed spine */}
                 <div

frontend/src/components/campaigns/CampaignsDashboardTab.jsx

@@ -85,6 +85,7 @@ function normalizeCampaign(c) {
             Math.round(c.generationProgressPercent ?? (genDone ? 100 : hasFile ? 0 : 100))
         ),
         sequence: Array.isArray(c.sequence) ? c.sequence : [],
+        parallelTracks: !!c.parallelTracks,
         executionProgressPercent: Math.min(
             100,
             Math.round(Number(c.executionProgressPercent) || 0)
@@ -660,6 +661,7 @@ export default function CampaignsDashboardTab() {
                 fileId: payload.fileId || null,
                 prospectFileName: payload.prospectFileName || '',
                 sequence: payload.sequence || [],
+                parallelTracks: !!payload.parallelTracks,
                 selectedProducts: payload.selectedProducts || [],
                 generationComplete: !!payload.generationComplete,
                 generationProgressPercent: Math.min(
@@ -732,6 +734,10 @@ export default function CampaignsDashboardTab() {
                 fileId: payload.fileId ?? base.fileId ?? null,
                 prospectFileName: payload.prospectFileName ?? base.prospectFileName ?? '',
                 sequence: Array.isArray(payload.sequence) ? payload.sequence : base.sequence || [],
+                parallelTracks:
+                    typeof payload.parallelTracks === 'boolean'
+                        ? payload.parallelTracks
+                        : !!base.parallelTracks,
                 selectedProducts: Array.isArray(payload.selectedProducts)
                     ? payload.selectedProducts
                     : base.selectedProducts || [],

frontend/src/components/campaigns/CreateCampaignWizard.jsx

@@ -63,7 +63,7 @@ function mailboxLabelForAppendixStep(step, mailboxDefaults) {
     return ((a?.display_name || a?.label || '') || '').trim();
 }
 
-function buildCampaignSequenceAppendix(steps, mailboxDefaults = null) {
+function buildCampaignSequenceAppendix(steps, mailboxDefaults = null, parallelTracks = false) {
     const lines = [
         WIZARD_SEQUENCE_TAG,
         '(AUTHORITATIVE — OVERRIDES ANY FIXED “N EMAILS” OR “N MESSAGES” COUNT IN THIS PROMPT)',
@@ -72,6 +72,12 @@ function buildCampaignSequenceAppendix(steps, mailboxDefaults = null) {
         'Respect wait steps as pacing context between touches (do not invent extra touches for waits).',
         '',
     ];
+    if (parallelTracks) {
+        lines.push(
+            'Execution note: Gmail and LinkedIn run on separate timelines — a wait after an email does not delay LinkedIn steps (and vice versa).',
+            ''
+        );
+    }
     let n = 0;
     (steps || []).forEach((s) => {
         if (s.type === 'wait') {
@@ -266,12 +272,19 @@ function WizardSequencePreview({
     );
 }
 
-function ReviewSequenceTimeline({ steps }) {
+function ReviewSequenceTimeline({ steps, parallelTracks }) {
     if (!steps?.length) {
         return <p className="text-sm text-slate-500">No sequence steps.</p>;
     }
     return (
-        <div className="flex flex-wrap items-center gap-1 py-2">
+        <div>
+            {parallelTracks ? (
+                <p className="mb-3 text-xs text-slate-600">
+                    Parallel tracks: Gmail and LinkedIn advance on separate timers — waits only apply within the same
+                    channel.
+                </p>
+            ) : null}
+            <div className="flex flex-wrap items-center gap-1 py-2">
             {steps.map((s, i) => (
                 <React.Fragment key={s.id || i}>
                     {i > 0 ? <ChevronRight className="mx-0.5 h-4 w-4 shrink-0 text-slate-300" /> : null}
@@ -301,6 +314,7 @@ function ReviewSequenceTimeline({ steps }) {
                     )}
                 </React.Fragment>
             ))}
+            </div>
         </div>
     );
 }
@@ -320,6 +334,7 @@ export default function CreateCampaignWizard({
     const [dragOver, setDragOver] = useState(false);
     const [estimatedContacts, setEstimatedContacts] = useState(0);
     const [sequenceSteps, setSequenceSteps] = useState(() => createDefaultSequenceSteps());
+    const [parallelTracks, setParallelTracks] = useState(false);
     const [linkedinDefaults, setLinkedinDefaults] = useState(null);
     const [mailboxDefaults, setMailboxDefaults] = useState(null);
 
@@ -362,6 +377,7 @@ export default function CreateCampaignWizard({
         setEstimatedContacts(0);
         setDragOver(false);
         setSequenceSteps(createDefaultSequenceSteps());
+        setParallelTracks(false);
         setSelectedProducts([]);
         setPrompts({});
         setLinkedinPrompts({});
@@ -424,6 +440,7 @@ export default function CreateCampaignWizard({
         } else {
             setSequenceSteps(createDefaultSequenceSteps());
         }
+        setParallelTracks(!!initialCampaign.parallelTracks);
         setSelectedProducts(
             Array.isArray(initialCampaign.selectedProducts) ? initialCampaign.selectedProducts : []
         );
@@ -574,7 +591,7 @@ export default function CreateCampaignWizard({
 
     useEffect(() => {
         if (step !== 3 || selectedProducts.length === 0) return;
-        const appendix = buildCampaignSequenceAppendix(sequenceSteps, mailboxDefaults);
+        const appendix = buildCampaignSequenceAppendix(sequenceSteps, mailboxDefaults, parallelTracks);
         setPrompts((prev) => {
             const next = { ...prev };
             let changed = false;
@@ -606,7 +623,7 @@ export default function CreateCampaignWizard({
             });
             return changed ? next : prev;
         });
-    }, [step, sequenceSteps, selectedProducts, sequenceHasLinkedin, mailboxDefaults]);
+    }, [step, sequenceSteps, selectedProducts, sequenceHasLinkedin, mailboxDefaults, parallelTracks]);
 
     useEffect(() => {
         if (!genRunning || !wizardUpload?.fileId) return;
@@ -760,6 +777,7 @@ export default function CreateCampaignWizard({
             prospectFileName: wizardUpload?.name || prospectFile?.name || '',
             fileId: wizardUpload?.fileId || null,
             sequence: sequenceSteps,
+            parallelTracks,
             selectedProducts,
             generationComplete: genComplete,
             generationProgressPercent: Math.min(100, Math.round(genProgress || 0)),
@@ -788,7 +806,9 @@ export default function CreateCampaignWizard({
                     prompts,
                     products: selectedProducts.map((p) => p.name),
                     linkedin_prompts: sequenceHasLinkedin ? linkedinPrompts : {},
-                    sequence_plan: sequenceSteps,
+                    sequence_plan: parallelTracks
+                        ? { parallel_tracks: true, steps: sequenceSteps }
+                        : sequenceSteps,
                 }),
             });
             if (!res.ok) {
@@ -816,6 +836,7 @@ export default function CreateCampaignWizard({
             prospectFileName: wizardUpload?.name || prospectFile?.name || '',
             fileId: wizardUpload?.fileId || null,
             sequence: sequenceSteps,
+            parallelTracks,
             selectedProducts,
             generationComplete: genComplete,
             generationProgressPercent: Math.min(100, Math.round(genProgress || 0)),
@@ -987,6 +1008,8 @@ export default function CreateCampaignWizard({
                         <CampaignSequenceBuilder
                             value={sequenceSteps}
                             onChange={setSequenceSteps}
+                            parallelTracks={parallelTracks}
+                            onParallelTracksChange={setParallelTracks}
                             linkedinDefaults={linkedinDefaults}
                             mailboxDefaults={mailboxDefaults}
                         />
@@ -1045,7 +1068,7 @@ export default function CreateCampaignWizard({
                         <div className="space-y-6">
                             <div className="rounded-xl border border-slate-200 bg-white p-4 shadow-sm">
                                 <p className="text-sm font-medium text-slate-800">Sequence</p>
-                                <ReviewSequenceTimeline steps={sequenceSteps} />
+                                <ReviewSequenceTimeline steps={sequenceSteps} parallelTracks={parallelTracks} />
                             </div>
                             <div>
                                 <p className="mb-2 text-sm font-medium text-slate-800">Sample preview</p>