Copy Connections Execute

Copy Connections — Execute

This skill performs the actual copy. It takes a validated plan and produces .copy-connections/results.md.

Execute does not handle credentials. Connections are created using run_setup_tests: false, which lets them be created without valid credentials. The copy-connections-credentials skill handles credential attachment as a separate, post-execute step.

Execute does not apply schema config. Schema config (which tables/columns are enabled, sync modes, hashing) requires a discovered schema, which only exists after credentials are attached and setup tests run. The copy-connections-schema skill handles this after credentials are in place.

Execute does not unpause connections. Connections are created paused by default. Unpausing is the user's responsibility after they've verified everything is in order.

Required checkpoints

1. Verify plan and validation report exist and match. Execute reads the plan's checksum from the validation report. If the plan has been modified since validation, refuse to run.
2. Verify validation status is pass or pass-with-warnings. If fail, refuse. If pass-with-warnings, surface them and require explicit user acknowledgment before proceeding.
3. Confirm user is ready to execute. Final yes/no before any writes.
4. Always use run_setup_tests: false on create_connection. We don't have credentials at this point; running tests would fail noisily.
5. Continue on per-connection failures. Don't abort the whole run if one connection fails. Log the failure and move to the next.
6. Produce results.md at the end regardless of outcome. Partial successes, full successes, and full failures all produce a results file.

Step-by-step

1. Pre-flight

Read .copy-connections/copy_plan.yaml and .copy-connections/validation_report.yaml. If either is missing, stop and tell the user which one to generate first (scope for plan, validate for report).

Compute the current checksum of copy_plan.yaml and compare to the checksum recorded in validation_report.yaml. If they don't match, refuse to run: the plan has been modified since validation. Tell the user to re-run validate.

Check validation status:

• fail → stop. Tell the user to re-scope based on the blocking issues.
• pass-with-warnings → surface each warning by code with its context, ask for explicit acknowledgment.
• pass → proceed without further ceremony.

Ask for final confirmation before any writes.

2. Destination setup (only if the target is new and wasn't created during scope)

Scope is responsible for creating the destination if it's new, because we need a working destination before we can fetch per-connection configs. In practice, if the user's flow was scope → validate → execute, the destination already exists.

If for some reason the destination doesn't exist yet (e.g., the user ran scope against an existing target that was later deleted), the validation report should have caught this as PLAN_STALE. If we get to execute and the destination is missing anyway, stop and re-scope.

3. For each connection in the plan

Process connections sequentially. For each one:

a. Check for idempotency. Call list_connections once at the start of execution and cache. If a connection with the target name already exists in the target group with a config that matches the plan, skip creation and log ALREADY_EXISTS. Don't attempt to update existing connections — too risky in v0.

b. Create the connection shell. Call create_connection with:

• Full config block from the plan (credential fields as empty strings)
• run_setup_tests: false (always — we don't have credentials)

All other fields from the plan's connection config are passed through verbatim. The connection is created paused by default. This is the Fivetran-side default behavior; we rely on it.

c. Log the result. Record per-connection: success or failure. Continue to the next connection regardless.

4. For each Quickstart transformation package in the plan

After all connections are created:

a. Verify dependencies are present. The package depends on one or more target connections existing. The validation step already checked this, but sanity-check against the actual execute results — if a dependency connection failed to create, skip the package and log.

b. Create the transformation. Call create_transformation referencing the package and the target destination.

c. Log the result. Success, skipped (missing dependency), or failure.

5. Write results.md

Write .copy-connections/results.md with:

# Copy Connections Results

**Date:** <ISO timestamp>
**Source:** <source group name>
**Target:** <target group name>

## Summary

- N connections created successfully
- K connections failed to create
- P Quickstart packages installed
- Q Quickstart packages failed or skipped

## Per-connection results

### salesforce_prod
- Created (paused)
- Auth: OAuth — complete authentication in the Fivetran UI: https://fivetran.com/dashboard/connections/<connection_id>

### postgres_app
- Created (paused)
- Auth: Password needed — attach via credentials skill or Fivetran UI: https://fivetran.com/dashboard/connections/<connection_id>

### stripe_prod
- Created (paused)
- Auth: API key needed — attach via credentials skill or Fivetran UI: https://fivetran.com/dashboard/connections/<connection_id>

## Transformations

- stripe_analytics Quickstart package installed

## Next steps

1. **Attach credentials.** Either:
   - Run the `copy-connections-credentials` skill: I'll help you attach credentials for credential-based connections and provide UI links for OAuth ones.
   - Or add credentials yourself in the Fivetran UI for each connection.

2. **Apply schema config.** After credentials are in place, run the `copy-connections-schema` skill to run setup tests and apply table/column selections, sync modes, and hashing from the plan.

3. **Unpause connections** when you're ready for them to sync. You can do this one at a time in the Fivetran UI, or via the `sync_connection` MCP tool.

4. **Recreate custom transformations** that were flagged during validation:
   - (list any CUSTOM_TRANSFORMATION_NOT_COPYABLE items from validation report here)

5. **After syncs complete**, consider comparing row counts between source and target connections to verify the copy.

## Cleanup

- Keep `.copy-connections/copy_plan.yaml` and `validation_report.yaml` for audit, or delete if you're done.
- If you used a credentials file during the credentials flow, delete it when you're done.

The results file is written even on failure — it's the source of truth for what happened.

6. Summarize to the user

Give a short verbal summary: what was created, what failed, and point at results.md for the full breakdown. Mention the next step: "Want me to help attach credentials? Or you can do it yourself in the Fivetran UI. After credentials are in place, we'll apply schema config."

Key product knowledge

run_setup_tests: false is the unlock here. Without it, create_connection would run setup tests that would fail because we have no credentials. With it, Fivetran creates the connection in a paused, untested state — which is exactly what we want. This is a first-class Fivetran API parameter, not a workaround.

Connections created without credentials are real connections. They appear in the Fivetran UI. They're just paused and untested. The user can see what got created before they add credentials.

Connections are paused by default after create_connection. Verified from real API responses (paused: true in the create response). We rely on this. Do not attempt to pause them explicitly after creation.

Idempotency is name-based, not config-based. If a connection with the target name exists in the target group, we skip creation. We don't try to diff configs and patch to match — that's v1+ territory. Users resuming a partial execute get "skipped" for already-created ones and creation for the rest.

Schema config happens later, not here. The schema doesn't exist until credentials are attached and setup tests discover the tables/columns. Execute creates the connection shell with the right config; schema config is applied by the copy-connections-schema skill after credentials are in place.

Never try to update existing connections. If a connection already exists with the target name, we skip. Full stop. Updating existing connections mid-execute is a foot-gun — the user might have intentionally set up something different and we'd clobber it.

Error handling

Connection creation fails for one connection. Log the error in results.md with the Fivetran error message. Continue to the next connection.

Destination is somehow missing when execute starts. This should have been caught by validation's PLAN_STALE check. If it slips through anyway, stop and tell the user to re-scope.

Partial run interrupted (user Ctrl-C, session ends, etc.). Results.md is written incrementally if possible — i.e., after each connection, not only at the very end. Users who interrupt can see what got done. They can re-run execute; idempotency will skip the already-created ones.

Quickstart package creation fails. Log and continue. The connections are still valid.

Anti-patterns to avoid

• Don't run setup tests during execute. We don't have credentials. Setup tests happen in the schema skill, after credentials are attached.
• Don't apply schema config during execute. The schema doesn't exist yet. That's the schema skill's job.
• Don't collect credentials during execute. Credentials are out of scope for this skill.
• Don't unpause connections. Not this skill's job.
• Don't abort on per-connection failures. Continue; log; report.
• Don't attempt to update existing connections. Skip them.
• Don't omit results.md on failure. It's the audit trail.
• Don't rollback on failure. If creation fails partway, the partial copy stays. User decides what to do. (v0 has no rollback mechanism; deleting a Fivetran group via the UI is the manual cleanup path.)