SnowConvert AI - Informatica PowerCenter¶

Session task¶

A Session in Informatica executes a Mapping at runtime. Each Session is converted into a Snowflake TASK that runs the corresponding dbt project.

Conversion output:

• A CREATE OR REPLACE TASK statement with AFTER dependency on the preceding task

• Variable initialization via BuildDbtVarsJsonUDF

• EXECUTE DBT PROJECT call with the variable JSON payload

Example:

CREATE OR REPLACE TASK public.wf_daily_load_s_load_customers
WAREHOUSE = DUMMY_WAREHOUSE
AFTER public.wf_daily_load
AS
BEGIN
    LET dbt_vars VARCHAR := public.BuildDbtVarsJsonUDF('wf_daily_load');
    EXECUTE DBT PROJECT public.m_load_customers ARGS = :dbt_vars;
END;

Notes:

• Replace DUMMY_WAREHOUSE with your actual Snowflake warehouse name

• The AFTER clause preserves the original Workflow execution order

• Reusable Sessions are resolved to reference the correct Mapping

Session overrides¶

Informatica Sessions can override properties defined at the Mapping level. SnowConvert AI captures these overrides and applies them during conversion.

Worklet task¶

Informatica Worklets are reusable, nested sub-workflows that can be embedded inside a parent Workflow. SnowConvert AI converts Worklets into nested Snowflake Task Graphs.

Conversion output:

• A separate SQL file per Worklet in the worklets/ directory

• The Worklet’s internal Start task and Session tasks are converted following the same patterns as the parent Workflow

• The parent Workflow references the Worklet root task via an AFTER dependency

Example structure:

{FolderName}/{MappingName}/
├── wf_daily_load.sql               # Parent Workflow
└── worklets/
    └── wklt_validate.sql             # Worklet sub-graph

The Worklet Task Graph preserves the original execution hierarchy. Worklet tasks follow the same naming and variable management patterns as the parent Workflow.

Start task¶

The Informatica Start task (the entry point of a Workflow) is converted into an initialization TASK that sets up the variable context:

CREATE OR REPLACE TASK public.wf_daily_load AS
BEGIN
    CALL public.InitVariablesFromConfig('wf_daily_load');
END;

This TASK loads default variable values and applies parameter file overrides before any Session tasks execute.

dbt project execution¶

Within the orchestration code, Sessions are executed using Snowflake’s EXECUTE DBT PROJECT command:

EXECUTE DBT PROJECT schema.project_name ARGS = :dbt_vars;

Important requirements:

• The project_name must match the name used when deploying the dbt project (via CREATE DBT PROJECT or Snowflake Workspace deployment)

• The ARGS parameter passes workflow variables as a JSON payload built by BuildDbtVarsJsonUDF

• Each execution runs the entire dbt project with all models in dependency order

Deployment options:

• Snowflake CLI: snow dbt deploy --schema schema_name --database database_name --force package_name

• Snowflake Workspace: Upload and deploy via UI

Variable management¶

Informatica variables ($$var assignments) are converted into a table-driven management system. The infrastructure components are generated in the etl_configuration/ folder.

Layer organization¶

dbt project structure¶

Each Mapping produces a standalone dbt project:

{MappingName}/
├── dbt_project.yml                   # Materialization config
├── profiles.yml                      # Snowflake connection profile
├── models/
│   ├── sources.yml                   # Source table definitions
│   ├── staging/
│   │   ├── stg_customers.sql
│   │   └── stg_regions.sql
│   ├── intermediate/
│   │   ├── int_expression.sql
│   │   └── int_joiner.sql
│   └── marts/
│       └── customer_dim.sql
└── macros/
    └── *.sql                         # Mapplet-derived macros

Expression functions¶

SnowConvert AI supports over 60 Informatica expression functions across the following categories:

Naming and sanitization rules¶

SnowConvert AI applies consistent sanitization rules to all Informatica object names to ensure dbt and Snowflake compatibility:

These rules apply uniformly across all generated artifacts: dbt model names, Snowflake TASK names, procedure names, and variable identifiers.