diff --git a/e2e_samples/fabric_dataops_sample/devops/scripts/cd_git_sync.py b/e2e_samples/fabric_dataops_sample/devops/scripts/cd_git_sync.py
new file mode 100644
index 000000000..cd50ce685
--- /dev/null
+++ b/e2e_samples/fabric_dataops_sample/devops/scripts/cd_git_sync.py
@@ -0,0 +1,103 @@
+import logging
+import os
+
+import utils
+
+# Configure logging
+logging.basicConfig(level=logging.INFO, format="[%(levelname)s] %(message)s")
+
+# Get bearer tokens and headers
+(
+    azure_management_headers,
+    azure_storage_headers,
+    fabric_headers,
+    azure_management_bearer_token,
+    azure_storage_bearer_token,
+    fabric_bearer_token,
+) = utils.get_bearer_tokens_and_headers()
+
+# Fabric environment variables
+fabric_capacity_name = os.environ.get("FABRIC_CAPACITY_NAME")
+fabric_workspace_name = os.environ.get("FABRIC_WORKSPACE_NAME")
+
+
+class ValidationError(Exception):
+    """Custom exception for validation errors."""
+
+    def __init__(self, message: str) -> None:
+        self.message = message
+        logging.error(self.message)
+        exit(1)
+
+
+def main() -> None:
+    """Main function to orchestrate the git sync process."""
+    validate_env()
+    logging.info("############ Workspace Related Tasks ############")
+    _ = get_capacity_details()
+    workspace_id = get_workspace_details()
+    logging.info("------------------ Accept Git changes and update the workspace ------------------")
+    sync_git_changes(workspace_id)
+    logging.info("------------------ Git Sync Completed ------------------")
+    logging.info("############ Workspace Related Tasks Completed ############")
+
+
+def validate_env() -> None:
+    """Validate the required environment variables and tokens."""
+    required_env_vars = [
+        "FABRIC_CAPACITY_NAME",
+        "FABRIC_WORKSPACE_NAME",
+    ]
+
+    error_list = [var for var in required_env_vars if not os.environ.get(var)]
+
+    if error_list:
+        raise ValidationError("The following mandatory environment variables are not set: " + ", ".join(error_list))
+
+
+def get_capacity_details() -> str:
+    """Retrieve and log the capacity details."""
+    capacity_id = utils.get_capacity_id(headers=fabric_headers, capacity_name=fabric_capacity_name)
+    if capacity_id:
+        logging.info(f"Capacity details: '{fabric_capacity_name}' ({capacity_id})")
+    else:
+        raise Exception(f"Failed to retrieve capacity ID for '{fabric_capacity_name}'")
+    return capacity_id
+
+
+def get_workspace_details() -> str:
+    """Retrieve and log the workspace details."""
+    workspace_id = utils.get_workspace_id(headers=fabric_headers, workspace_name=fabric_workspace_name)
+    if workspace_id:
+        logging.info(f"Workspace '{fabric_workspace_name}' already exists.")
+        logging.info(f"Workspace details: '{fabric_workspace_name}' ({workspace_id})")
+    else:
+        raise Exception(f"Workspace '{fabric_workspace_name}' doesn't exist.")
+    return workspace_id
+
+
+def sync_git_changes(workspace_id: str) -> None:
+    """Sync git changes and update the workspace."""
+    git_status = utils.get_workspace_git_status(fabric_headers, workspace_id)
+    if not git_status:
+        logging.error("Workspace is not connected to git. Please check the workspace.")
+    else:
+        workspace_head = git_status.get("workspaceHead")
+        remote_commit_hash = git_status.get("remoteCommitHash")
+        logging.info(f"workspace_head: {workspace_head}")
+        logging.info(f"remote_commit_hash: {remote_commit_hash}")
+
+        if workspace_head != remote_commit_hash:
+            logging.info("Accept Git changes and update the workspace")
+            utils.update_workspace_from_git(
+                headers=fabric_headers,
+                workspace_id=workspace_id,
+                commit_hash=remote_commit_hash,
+                workspace_head=workspace_head,
+            )
+        else:
+            logging.info("No new commit to update the workspace")
+
+
+if __name__ == "__main__":
+    main()
diff --git a/e2e_samples/fabric_dataops_sample/devops/scripts/cd_ws_item_sync.py b/e2e_samples/fabric_dataops_sample/devops/scripts/cd_ws_item_sync.py
new file mode 100644
index 000000000..1fc13c73c
--- /dev/null
+++ b/e2e_samples/fabric_dataops_sample/devops/scripts/cd_ws_item_sync.py
@@ -0,0 +1,253 @@
+import logging
+import os
+import time
+
+import utils
+import yaml
+
+# Configure logging
+logging.basicConfig(level=logging.INFO, format="[%(levelname)s] %(message)s")
+
+update_spark_compute_settings = True
+update_public_libraries = True
+update_custom_libraries = True
+
+# Get bearer tokens and headers
+(
+    azure_management_headers,
+    azure_storage_headers,
+    fabric_headers,
+    azure_management_bearer_token,
+    azure_storage_bearer_token,
+    fabric_bearer_token,
+) = utils.get_bearer_tokens_and_headers()
+
+# Environment Variables
+ci_artifacts_path = os.environ.get("CI_ARTIFACTS_PATH")
+
+# Azure Resources
+storage_account_name = os.environ.get("STORAGE_ACCOUNT_NAME")
+storage_container_name = os.environ.get("STORAGE_CONTAINER_NAME")
+
+# Fabric
+fabric_capacity_name = os.environ.get("FABRIC_CAPACITY_NAME")
+fabric_workspace_name = os.environ.get("FABRIC_WORKSPACE_NAME")
+fabric_environment_name = os.environ.get("FABRIC_ENVIRONMENT_NAME")
+fabric_custom_pool_name = os.environ.get("FABRIC_CUSTOM_POOL_NAME")
+fabric_connection_name = os.environ.get("FABRIC_ADLS_CONNECTION_NAME")
+fabric_lakehouse_name = os.environ.get("FABRIC_LAKEHOUSE_NAME")
+fabric_shortcut_name = os.environ.get("FABRIC_ADLS_SHORTCUT_NAME")
+
+
+class ValidationError(Exception):
+    """Custom exception for validation errors."""
+
+    def __init__(self, message: str) -> None:
+        self.message = message
+        logging.error(self.message)
+        exit(1)
+
+
+def main() -> None:
+    """Main function to orchestrate the workspace item sync process."""
+    validate_env()
+    _ = get_capacity_details()
+    logging.info("############ Workspace Related Tasks ############")
+    workspace_id = get_workspace_details()
+    connection_id = get_connection_details()
+    create_shortcut(workspace_id, connection_id)
+    logging.info("############ Environment Related Tasks ############")
+    environment_id = utils.get_environment_id(fabric_headers, workspace_id, fabric_environment_name)
+    if environment_id:
+        logging.info(f"Environment details: '{fabric_environment_name}' ({environment_id})")
+    else:
+        raise Exception(f"Failed to retrieve environment id for '{fabric_environment_name}'")
+    logging.info("------------------ Custom Pool Related Tasks ------------------")
+    update_custom_pool(workspace_id)
+    logging.info("------------------ Public and Custom Library Related Tasks ------------------")
+    update_libraries(workspace_id, environment_id)
+    logging.info("------------------ Publish environment if there are staged changes ------------------")
+    publish_environment_if_needed(workspace_id, environment_id)
+    logging.info("############ Workspace Related Tasks Completed ############")
+
+
+def validate_env() -> None:
+    """Validate the required environment variables and tokens."""
+    required_env_vars = [
+        "STORAGE_ACCOUNT_NAME",
+        "STORAGE_CONTAINER_NAME",
+        "FABRIC_CAPACITY_NAME",
+        "FABRIC_WORKSPACE_NAME",
+        "FABRIC_ENVIRONMENT_NAME",
+        "FABRIC_CUSTOM_POOL_NAME",
+        "FABRIC_ADLS_CONNECTION_NAME",
+        "FABRIC_LAKEHOUSE_NAME",
+        "FABRIC_ADLS_SHORTCUT_NAME",
+        "CI_ARTIFACTS_PATH",
+    ]
+
+    error_list = [var for var in required_env_vars if not os.environ.get(var)]
+
+    if error_list:
+        raise ValidationError("The following mandatory environment variables are not set: " + ", ".join(error_list))
+
+
+def get_capacity_details() -> str:
+    """Retrieve and log the capacity details."""
+    capacity_id = utils.get_capacity_id(headers=fabric_headers, capacity_name=fabric_capacity_name)
+    if capacity_id:
+        logging.info(f"Capacity details: '{fabric_capacity_name}' ({capacity_id})")
+    else:
+        raise Exception(f"Failed to retrieve capacity ID for '{fabric_capacity_name}'")
+    return capacity_id
+
+
+def get_workspace_details() -> str:
+    """Retrieve and log the workspace details."""
+    workspace_id = utils.get_workspace_id(headers=fabric_headers, workspace_name=fabric_workspace_name)
+    if workspace_id:
+        logging.info(f"Workspace '{fabric_workspace_name}' already exists.")
+        logging.info(f"Workspace details: '{fabric_workspace_name}' ({workspace_id})")
+    else:
+        raise Exception(f"Workspace '{fabric_workspace_name}' doesn't exist.")
+    return workspace_id
+
+
+def get_connection_details() -> str:
+    """Create and log the connection details."""
+    connection_id = utils.get_connection_id(fabric_headers, fabric_connection_name)
+    if connection_id:
+        logging.info(f"Connection '{fabric_connection_name}' already exists.")
+    else:
+        raise Exception(f"Failed to retrieve connection id for '{fabric_connection_name}'")
+    return connection_id
+
+
+def create_shortcut(workspace_id: str, connection_id: str) -> None:
+    """Create and log the shortcut details."""
+    storage_account_url = f"https://{storage_account_name}.dfs.core.windows.net"
+    lakehouse_id = utils.get_item_id(fabric_headers, workspace_id, "Lakehouse", fabric_lakehouse_name)
+    if lakehouse_id:
+        logging.info(f"Lakehouse details: '{fabric_lakehouse_name}' ({lakehouse_id})")
+
+        if utils.get_shortcut(fabric_headers, workspace_id, lakehouse_id, "Files", fabric_shortcut_name):
+            logging.info(f"Shortcut '{fabric_shortcut_name}' already exists.")
+        else:
+            logging.info(f"Shortcut '{fabric_shortcut_name}' doesn't exist. Creating shortcut.")
+            target = {
+                "adlsGen2": {
+                    "connectionId": connection_id,
+                    "location": storage_account_url,
+                    "subpath": storage_container_name,
+                }
+            }
+            logging.info(target)
+            utils.create_shortcut(fabric_headers, workspace_id, lakehouse_id, "Files", fabric_shortcut_name, target)
+    else:
+        raise Exception(f"Failed to retrieve lakehouse id for '{fabric_lakehouse_name}'")
+
+
+def update_custom_pool(workspace_id: str) -> None:
+    """Update the custom pool if necessary."""
+    current_custom_pool = utils.get_custom_pool_by_name(
+        headers=fabric_headers, workspace_id=workspace_id, custom_pool_name=fabric_custom_pool_name
+    )
+
+    if update_spark_compute_settings:
+        env_files_dir = os.path.join(ci_artifacts_path, "./fabric_env")
+        yaml_file_path = os.path.join(env_files_dir, "spark_pool_settings.yml")
+        with open(yaml_file_path, "r") as file:
+            latest_custom_pool = yaml.safe_load(file)
+        if latest_custom_pool is not None and current_custom_pool is not None:
+            latest_custom_pool["id"] = current_custom_pool["id"]
+            latest_custom_pool["name"] = fabric_custom_pool_name
+            latest_custom_pool["type"] = "Workspace"
+
+            # If the custom pool details are different, update the custom pool
+            if current_custom_pool != latest_custom_pool:
+                logging.info(f"Current custom pool details: {current_custom_pool}")
+                logging.info(f"Latest custom pool details: {latest_custom_pool}")
+                logging.info(f"Updating custom pool '{fabric_custom_pool_name}' details.")
+                utils.update_workspace_custom_pool(
+                    fabric_headers, workspace_id, current_custom_pool["id"], latest_custom_pool
+                )
+            else:
+                logging.info("No changes in the custom pool")
+
+
+def update_libraries(workspace_id: str, environment_id: str) -> None:
+    """Update public and custom libraries."""
+    if update_public_libraries:
+        public_libs_dir = os.path.join(ci_artifacts_path, "./fabric_env/")
+        list_of_files = ["environment.yml"]
+        for file_name in os.listdir(public_libs_dir):
+            if file_name in list_of_files:
+                utils.upload_staging_library(
+                    headers=fabric_headers,
+                    workspace_id=workspace_id,
+                    environment_id=environment_id,
+                    file_path=public_libs_dir,
+                    file_name=file_name,
+                    content_type="multipart/form-data",
+                )
+
+    if update_custom_libraries:
+        library_files_dir = os.path.join(ci_artifacts_path, "./fabric_env/custom_libraries")
+        list_of_files = [
+            "ddo_transform_transform.py",
+            "ddo_transform_standardize.py",
+            "otel_monitor_invoker.py",
+        ]
+        for file_name in os.listdir(library_files_dir):
+            if file_name in list_of_files:
+                utils.upload_staging_library(
+                    headers=fabric_headers,
+                    workspace_id=workspace_id,
+                    environment_id=environment_id,
+                    file_path=library_files_dir,
+                    file_name=file_name,
+                    content_type="application/x-python-wheel",
+                )
+
+
+def publish_environment_if_needed(workspace_id: str, environment_id: str) -> None:
+    """Publish the environment if there are staged changes."""
+    staging_spark_compute_settings = utils.get_spark_compute_settings(
+        headers=fabric_headers, workspace_id=workspace_id, environment_id=environment_id, status="staging"
+    )
+    staging_libraries = utils.get_libraries(
+        headers=fabric_headers, workspace_id=workspace_id, environment_id=environment_id, status="staging"
+    )
+
+    published_spark_compute_settings = utils.get_spark_compute_settings(
+        headers=fabric_headers, workspace_id=workspace_id, environment_id=environment_id, status="published"
+    )
+    published_libraries = utils.get_libraries(
+        headers=fabric_headers, workspace_id=workspace_id, environment_id=environment_id, status="published"
+    )
+
+    logging.info(f"staging_spark_compute_settings = {staging_spark_compute_settings}")
+    logging.info(f"published_spark_compute_settings = {published_spark_compute_settings}")
+
+    logging.info(f"staging_libraries = {staging_libraries}")
+    logging.info(f"published_libraries = {published_libraries}")
+
+    if (staging_spark_compute_settings != published_spark_compute_settings) or (staging_libraries is not None):
+        logging.info("There are changes in spark compute settings or libraries. Publishing the environment.")
+        logging.info("---------------------- Publishing environment ----------------------")
+        utils.publish_environment(headers=fabric_headers, workspace_id=workspace_id, environment_id=environment_id)
+
+        # Polling environment status
+        while utils.get_publish_environment_status(fabric_headers, workspace_id, environment_id).lower() in [
+            "running",
+            "waiting",
+        ]:
+            logging.info("Environment publishing is in progress.")
+            time.sleep(60)
+        logging.info("Environment publishing completed.")
+    else:
+        logging.info("There are no changes in spark compute settings or libraries. Publishing the environment.")
+
+
+if __name__ == "__main__":
+    main()
diff --git a/e2e_samples/fabric_dataops_sample/devops/scripts/utils.py b/e2e_samples/fabric_dataops_sample/devops/scripts/utils.py
index c3c4e6a2b..4cb202aad 100644
--- a/e2e_samples/fabric_dataops_sample/devops/scripts/utils.py
+++ b/e2e_samples/fabric_dataops_sample/devops/scripts/utils.py
@@ -1,8 +1,9 @@
 import json
 import os
+import subprocess
 import time
 import uuid
-from typing import List, Optional
+from typing import Dict, List, Optional, Tuple
 
 import requests
 from requests.structures import CaseInsensitiveDict
@@ -848,3 +849,68 @@ def delete_storage_container(headers: dict, storage_account_name: str, storage_c
         print("[Info] Container already deleted or does not exist.")
     else:
         raise Exception(f"[Error] Delete container request failed': {response.status_code} - {response.text}")
+
+
+def get_lakehouse_id(headers: dict, workspace_id: str, lakehouse_name: str) -> Optional[str]:
+    url = f"{fabric_api_endpoint}/workspaces/{workspace_id}/items"
+
+    response = requests.get(url, headers=headers)
+
+    if response.status_code == 200:
+        items = response.json().get("value", [])
+
+        for item in items:
+            if item.get("displayName") == lakehouse_name and item.get("type") == "Lakehouse":
+                return item.get("id")
+        print(f"[Info] Lakehouse '{lakehouse_name}' not found.")
+        return None
+    elif response.status_code == 404:
+        print(f"[Info] No items found. Response: {response.text}")
+        return None
+    else:
+        raise Exception(f"[Error] Failed to retrieve items: {response.status_code} - {response.text}")
+
+
+def get_bearer_tokens_and_headers() -> Tuple[Dict[str, str], Dict[str, str], Dict[str, str], str, str, str]:
+    fabric_bearer_token = (
+        subprocess.check_output(
+            "az account get-access-token --resource https://api.fabric.microsoft.com --query accessToken -o tsv",
+            shell=True,
+        )
+        .decode("utf-8")
+        .strip()
+    )
+
+    azure_management_bearer_token = (
+        subprocess.check_output(
+            "az account get-access-token --resource https://management.azure.com --query accessToken -o tsv",
+            shell=True,
+        )
+        .decode("utf-8")
+        .strip()
+    )
+
+    azure_storage_bearer_token = (
+        subprocess.check_output(
+            "az account get-access-token --resource https://storage.azure.com/ --query accessToken -o tsv",
+            shell=True,
+        )
+        .decode("utf-8")
+        .strip()
+    )
+
+    azure_management_headers = {
+        "Authorization": f"Bearer {azure_management_bearer_token}",
+        "Content-Type": "application/json",
+    }
+    azure_storage_headers = {"Authorization": f"Bearer {azure_storage_bearer_token}", "x-ms-version": "2021-02-12"}
+    fabric_headers = {"Authorization": f"Bearer {fabric_bearer_token}", "Content-Type": "application/json"}
+
+    return (
+        azure_management_headers,
+        azure_storage_headers,
+        fabric_headers,
+        azure_management_bearer_token,
+        azure_storage_bearer_token,
+        fabric_bearer_token,
+    )
diff --git a/e2e_samples/fabric_dataops_sample/devops/templates/jobs/publish-fabric-env-artifacts.yml b/e2e_samples/fabric_dataops_sample/devops/templates/jobs/publish-fabric-env-artifacts.yml
index d3788bcdf..bae6fdcb1 100644
--- a/e2e_samples/fabric_dataops_sample/devops/templates/jobs/publish-fabric-env-artifacts.yml
+++ b/e2e_samples/fabric_dataops_sample/devops/templates/jobs/publish-fabric-env-artifacts.yml
@@ -31,6 +31,7 @@ jobs:
       - script: |
           mkdir fabric_env/
           cp fabric/fabric_environment/environment.yml fabric_env/
+          cp fabric/fabric_environment/spark_pool_settings.yml fabric_env/
 
           mkdir fabric_env/custom_libraries/
           cp libraries/src/ddo_transform_standardize.py fabric_env/custom_libraries/
diff --git a/e2e_samples/fabric_dataops_sample/devops/templates/pipelines/azure-pipelines-cd-dev.yml b/e2e_samples/fabric_dataops_sample/devops/templates/pipelines/azure-pipelines-cd-dev.yml
new file mode 100644
index 000000000..d586cee64
--- /dev/null
+++ b/e2e_samples/fabric_dataops_sample/devops/templates/pipelines/azure-pipelines-cd-dev.yml
@@ -0,0 +1,75 @@
+trigger: none
+
+pr: none
+
+resources:
+  pipelines:
+    - pipeline: ciartifacts
+      source: pl-<BASE_NAME>-ci-publish-artifacts
+      trigger:
+        branches:
+          - <ENV1_BRANCH_NAME>
+
+variables:
+  - ${{ if eq(variables['Build.SourceBranchName'], '<ENV1_BRANCH_NAME>') }}:
+      - group: <ENV1_VARIABLE_GROUP_NAME>
+
+pool:
+  vmImage: 'ubuntu-latest'
+
+stages:
+  - stage: Perform_CD
+    jobs:
+      - job: Perform_CD
+        displayName: 'Perform CD steps'
+        steps:
+          - script: |
+              echo "Triggering interactive Azure CLI login..."
+              az login --use-device-code
+            displayName: 'Azure CLI - Interactive Login'
+
+          - task: UsePythonVersion@0
+            inputs:
+              versionSpec: '3.8'
+              addToPath: true
+
+          - download: ciartifacts
+            artifact: adls
+            displayName: 'Download ADLS Config Artifacts'
+          - download: ciartifacts
+            artifact: fabric_env
+            displayName: 'Download Fabric Environment Config Artifacts'
+          - script: |
+              echo "Artifacts downloaded"
+              ls -ltraR $(Pipeline.Workspace)/ciartifacts  # Verify files are downloaded
+            displayName: 'List all artifacts'
+
+          - script: |
+              pip install -r $(Build.SourcesDirectory)/devops/scripts/requirements.txt
+            displayName: 'Install Requirements'
+
+          - script: |
+
+              python -u $(Build.SourcesDirectory)/devops/scripts/cd_git_sync.py --verbose
+            displayName: 'Perform git sync'
+
+          - script: |
+              export CI_ARTIFACTS_PATH="$(Pipeline.Workspace)/ciartifacts"
+
+              python -u $(Build.SourcesDirectory)/devops/scripts/cd_ws_item_sync.py --verbose
+            displayName: 'Perform Workspace Item sync'
+
+
+          - script: |
+              export CI_ARTIFACTS_PATH="$(Pipeline.Workspace)/ciartifacts"
+
+              az storage blob upload-batch \
+                --account-name $STORAGE_ACCOUNT_NAME \
+                -d $STORAGE_CONTAINER_NAME \
+                -s ${CI_ARTIFACTS_PATH}/adls \
+                --auth-mode login \
+                --overwrite true \
+                --output none
+
+            displayName: 'Upload ADLS Config Artifacts'
+            workingDirectory: $(Build.SourcesDirectory)
diff --git a/e2e_samples/fabric_dataops_sample/devops/templates/pipelines/azure-pipelines-cd-stg_and_prod.yml b/e2e_samples/fabric_dataops_sample/devops/templates/pipelines/azure-pipelines-cd-stg_and_prod.yml
new file mode 100644
index 000000000..125399920
--- /dev/null
+++ b/e2e_samples/fabric_dataops_sample/devops/templates/pipelines/azure-pipelines-cd-stg_and_prod.yml
@@ -0,0 +1,83 @@
+trigger:
+  branches:
+    include:
+      - <ENV2_BRANCH_NAME>
+      - <ENV3_BRANCH_NAME>
+
+pr: none
+
+variables:
+  - ${{ if eq(variables['Build.SourceBranchName'], '<ENV2_BRANCH_NAME>') }}:
+      - group: <ENV2_VARIABLE_GROUP_NAME>
+  - ${{ elseif eq(variables['Build.SourceBranchName'], '<ENV3_BRANCH_NAME>') }}:
+      - group: <ENV3_VARIABLE_GROUP_NAME>
+
+pool:
+  vmImage: 'ubuntu-latest'
+
+stages:
+  - stage: Perform_CD
+    jobs:
+      - job: Perform_CD
+        displayName: 'Perform CD steps'
+        steps:
+          - script: |
+              echo "Triggering interactive Azure CLI login..."
+              az login --use-device-code
+            displayName: 'Azure CLI - Interactive Login'
+
+          - task: UsePythonVersion@0
+            inputs:
+              versionSpec: '3.8'
+              addToPath: true
+
+          - script: |
+              pip install -r $(Build.SourcesDirectory)/devops/scripts/requirements.txt
+            displayName: 'Install Requirements'
+
+          - script: |
+              python -u $(Build.SourcesDirectory)/devops/scripts/cd_git_sync.py --verbose
+            displayName: 'Perform git sync'
+
+          - script: |
+
+              echo "Creating artifacts"
+              mkdir fabric_env/
+              cp fabric/fabric_environment/environment.yml fabric_env/
+              cp fabric/fabric_environment/spark_pool_settings.yml fabric_env/
+
+              mkdir fabric_env/custom_libraries/
+              cp libraries/src/ddo_transform_standardize.py fabric_env/custom_libraries/
+              cp libraries/src/ddo_transform_transform.py fabric_env/custom_libraries/
+              cp libraries/src/otel_monitor_invoker.py fabric_env/custom_libraries/
+
+            displayName: 'Build Fabric Environment Config Artifacts'
+            workingDirectory: $(Build.SourcesDirectory)
+
+
+          - script: |
+              export CI_ARTIFACTS_PATH="$(Build.SourcesDirectory)"
+              python -u $(Build.SourcesDirectory)/devops/scripts/cd_ws_item_sync.py --verbose
+            displayName: 'Perform Workspace Item sync'
+
+
+          - script: |
+
+              echo "generate FABRIC_BEARER_TOKEN"
+              FABRIC_BEARER_TOKEN=$(az account get-access-token --resource https://api.fabric.microsoft.com --query accessToken -o tsv)
+
+              export FABRIC_BEARER_TOKEN=$FABRIC_BEARER_TOKEN
+
+              chmod +x devops/scripts/build_adls_files.sh
+              ./devops/scripts/build_adls_files.sh
+
+              az storage blob upload-batch \
+                --account-name $STORAGE_ACCOUNT_NAME \
+                -d $STORAGE_CONTAINER_NAME \
+                -s adls \
+                --auth-mode login \
+                --overwrite true \
+                --output none
+
+            displayName: 'Generate and Upload ADLS Config Artifacts'
+            workingDirectory: $(Build.SourcesDirectory)
diff --git a/e2e_samples/fabric_dataops_sample/devops/templates/pipelines/azure-pipelines-ci-artifacts.yml b/e2e_samples/fabric_dataops_sample/devops/templates/pipelines/azure-pipelines-ci-artifacts.yml
index c150a7c0e..a14fb7cc4 100644
--- a/e2e_samples/fabric_dataops_sample/devops/templates/pipelines/azure-pipelines-ci-artifacts.yml
+++ b/e2e_samples/fabric_dataops_sample/devops/templates/pipelines/azure-pipelines-ci-artifacts.yml
@@ -2,12 +2,6 @@ trigger:
   branches:
     include:
       - <ENV1_BRANCH_NAME>
-      - <ENV2_BRANCH_NAME>
-      - <ENV3_BRANCH_NAME>
-  paths:
-    exclude:
-      - fabric/workspace
-      - devops
 
 pr: none
 
@@ -23,27 +17,3 @@ stages:
         parameters:
           serviceConnection: <ENV1_SERVICE_CONNECTION_NAME>
       - template: templates/jobs/publish-fabric-env-artifacts.yml
-
-  - stage: publish_stg_artifacts
-    displayName: 'Publish artifacts for staging environment'
-    condition: |
-      eq(variables['Build.SourceBranchName'], '<ENV2_BRANCH_NAME>')
-    variables:
-      - group: <ENV2_VARIABLE_GROUP_NAME>
-    jobs:
-      - template: templates/jobs/publish-adls-artifacts.yml
-        parameters:
-          serviceConnection: <ENV2_SERVICE_CONNECTION_NAME>
-      - template: templates/jobs/publish-fabric-env-artifacts.yml
-
-  - stage: publish_prod_artifacts
-    displayName: 'Publish artifacts for production environment'
-    condition: |
-      eq(variables['Build.SourceBranchName'], '<ENV3_BRANCH_NAME>')
-    variables:
-      - group: <ENV3_VARIABLE_GROUP_NAME>
-    jobs:
-      - template: templates/jobs/publish-adls-artifacts.yml
-        parameters:
-          serviceConnection: <ENV3_SERVICE_CONNECTION_NAME>
-      - template: templates/jobs/publish-fabric-env-artifacts.yml
diff --git a/e2e_samples/fabric_dataops_sample/prepare_azure_repo.sh b/e2e_samples/fabric_dataops_sample/prepare_azure_repo.sh
index 035e67a7c..d70bdc311 100755
--- a/e2e_samples/fabric_dataops_sample/prepare_azure_repo.sh
+++ b/e2e_samples/fabric_dataops_sample/prepare_azure_repo.sh
@@ -26,16 +26,22 @@ echo "[Info] ############   CREATING AZDO PIPELINE FILES   ############"
 ci_artifacts_pipeline_template="devops/templates/pipelines/azure-pipelines-ci-artifacts.yml"
 ci_qa_cleanup_pipeline_template="devops/templates/pipelines/azure-pipelines-ci-qa-cleanup.yml"
 ci_qa_pipeline_template="devops/templates/pipelines/azure-pipelines-ci-qa.yml"
+cd_dev_pipeline_template="devops/templates/pipelines/azure-pipelines-cd-dev.yml"
+cd_stg_and_prod_pipeline_template="devops/templates/pipelines/azure-pipelines-cd-stg_and_prod.yml"
 
 # Azure DevOps (AzDo) pipeline actual files (to be created)
 ci_artifacts_pipeline="devops/azure-pipelines-ci-artifacts.yml"
 ci_qa_cleanup_pipeline="devops/azure-pipelines-ci-qa-cleanup.yml"
 ci_qa_pipeline="devops/azure-pipelines-ci-qa.yml"
+cd_dev_pipeline="devops/azure-pipelines-cd-dev.yml"
+cd_stg_and_prod_pipeline="devops/azure-pipelines-cd-stg_and_prod.yml"
 
 # Copy the pipeline template files to the actual pipeline files
 cp "$ci_artifacts_pipeline_template" "$ci_artifacts_pipeline"
 cp "$ci_qa_cleanup_pipeline_template" "$ci_qa_cleanup_pipeline"
 cp "$ci_qa_pipeline_template" "$ci_qa_pipeline"
+cp "$cd_dev_pipeline_template" "$cd_dev_pipeline"
+cp "$cd_stg_and_prod_pipeline_template" "$cd_stg_and_prod_pipeline"
 
 for i in "${!ENVIRONMENT_NAMES[@]}"; do
   environment_name="${ENVIRONMENT_NAMES[$i]}"
@@ -65,6 +71,15 @@ for i in "${!ENVIRONMENT_NAMES[@]}"; do
   replace "$placeholder_branch_name" "$azdo_git_branch_name" "$ci_qa_pipeline"
   replace "$placeholder_variable_group_name" "$azdo_variable_group_name" "$ci_qa_pipeline"
   replace "$placeholder_service_connection_name" "$azdo_service_connection_name" "$ci_qa_pipeline"
+
+  replace "$placeholder_branch_name" "$azdo_git_branch_name" "$cd_dev_pipeline"
+  replace "$placeholder_variable_group_name" "$azdo_variable_group_name" "$cd_dev_pipeline"
+  replace "$placeholder_service_connection_name" "$azdo_service_connection_name" "$cd_dev_pipeline"
+  replace "<BASE_NAME>" "$base_name" "$cd_dev_pipeline"
+
+  replace "$placeholder_branch_name" "$azdo_git_branch_name" "$cd_stg_and_prod_pipeline"
+  replace "$placeholder_variable_group_name" "$azdo_variable_group_name" "$cd_stg_and_prod_pipeline"
+  replace "$placeholder_service_connection_name" "$azdo_service_connection_name" "$cd_stg_and_prod_pipeline"
 done
 
 echo "[Info] ############    AZDO PIPELINE FILES CREATED   ############"
diff --git a/e2e_samples/fabric_dataops_sample/scripts/deploy_azdo_pipelines.sh b/e2e_samples/fabric_dataops_sample/scripts/deploy_azdo_pipelines.sh
index e93254249..18ee502f1 100755
--- a/e2e_samples/fabric_dataops_sample/scripts/deploy_azdo_pipelines.sh
+++ b/e2e_samples/fabric_dataops_sample/scripts/deploy_azdo_pipelines.sh
@@ -19,6 +19,8 @@ set -o nounset
 azdo_pipeline_ci_qa="pl-${BASE_NAME}-ci-qa"
 azdo_pipeline_ci_qa_cleanup="pl-${BASE_NAME}-ci-qa-cleanup"
 azdo_pipeline_ci_publish_artifacts="pl-${BASE_NAME}-ci-publish-artifacts"
+azdo_pipeline_cd_dev="pl-${BASE_NAME}-cd-dev"
+azdo_pipeline_cd_stg_and_prod="pl-${BASE_NAME}-cd-stg_and_prod"
 azdo_pipeline_variable_pr_id="PR_ID"
 
 get_azdo_repo_id () {
@@ -189,6 +191,18 @@ create_azdo_pipeline \
   "This pipeline publishes the build artifacts after the PR is merged to dev/stg/prod branches." \
   "/devops/azure-pipelines-ci-artifacts.yml"
 
+create_azdo_pipeline \
+  "$azdo_pipeline_cd_dev" \
+  "$AZDO_PIPELINES_BRANCH_NAME" \
+  "This pipeline perform deployment to dev branch." \
+  "/devops/azure-pipelines-cd-dev.yml"
+
+create_azdo_pipeline \
+  "$azdo_pipeline_cd_stg_and_prod" \
+  "$AZDO_PIPELINES_BRANCH_NAME" \
+  "This pipeline perform deployment to stg and prod branches." \
+  "/devops/azure-pipelines-cd-stg_and_prod.yml"
+
 create_azdo_pipeline_variable \
   "$azdo_pipeline_ci_qa_cleanup" \
   "$azdo_pipeline_variable_pr_id"