diff --git a/NEW/src/JdeScoping.DataSync.Dev/BranchDevEtl.cs b/NEW/src/JdeScoping.DataSync.Dev/BranchDevEtl.cs
index de04788..ebd3803 100644
--- a/NEW/src/JdeScoping.DataSync.Dev/BranchDevEtl.cs
+++ b/NEW/src/JdeScoping.DataSync.Dev/BranchDevEtl.cs
@@ -1,6 +1,5 @@
 using JdeScoping.DataAccess.Interfaces;
 using JdeScoping.DataSync.Etl.Destinations;
-using JdeScoping.DataSync.Dev.Models;
 using JdeScoping.DataSync.Etl.Pipeline;
 using JdeScoping.DataSync.Dev.Sources;
 
@@ -12,14 +11,7 @@ namespace JdeScoping.DataSync.Dev;
 public static class BranchDevEtl
 {
     public static readonly string TableName = "Branch";
-    public static readonly string CacheFileName = "branch.json.zstd";
-
-    private static readonly JsonColumnSchema[] Schema =
-    [
-        new("Code", typeof(string), IsNullable: false),
-        new("Description", typeof(string), IsNullable: true),
-        new("LastUpdateDT", typeof(DateTime), IsNullable: false),
-    ];
+    public static readonly string CacheFileName = "branch.pb.zstd";
 
     public static EtlPipeline Create(IDbConnectionFactory connectionFactory, string cacheFilePath)
     {
@@ -30,7 +22,7 @@ public static class BranchDevEtl
 
         return new EtlPipelineBuilder()
             .WithName($"{TableName}_Dev")
-            .WithSource(new JsonZstdFileSource(cacheFilePath, Schema))
+            .WithSource(new ProtobufZstdFileSource(cacheFilePath))
             .WithDestination(new DbBulkImportDestination(connectionFactory, TableName))
             .Build();
     }