diff --git a/R/cogifier_mil.R b/R/cogifier_mil.R
new file mode 100644
index 0000000000000000000000000000000000000000..06ba680eedc126e79df3d7e1dd4e06d6fea26680
--- /dev/null
+++ b/R/cogifier_mil.R
@@ -0,0 +1,7 @@
+# cogifier mil : ajout d'un paramètre mil à la fonction cogifier de COGiter 
+# pour pouvoir mettre à jour toutes les tables cogifiées dès lors que le paramètre de millésime bouge
+
+
+cogifier_mil <- function(mil, ...) {
+  COGiter::cogifier(...)
+}
\ No newline at end of file
diff --git a/_targets.R b/_targets.R
index c2c9540231a6b8080d7cbfd547525d6681c32d6a..2c306968645e9e498db98c1ccd54088a75b32f5e 100644
--- a/_targets.R
+++ b/_targets.R
@@ -9,10 +9,10 @@ tar_option_set(packages = packages)
 
 source("R/load_agri.R", encoding = "UTF-8")
 source("R/load_ecln.R", encoding = "UTF-8")
-
-con <- datalibaba::connect_to_db()
+source("R/cogifier_mil.R", encoding = "UTF-8")
 
 root <- "X:/SCTE/DOES/IT/"
+mil_cog <- "2022"
 
 list(
     tar_target(
@@ -27,25 +27,18 @@ list(
       ),
     tar_target(
       post_agri,#Nom de l'étape
-      datalibaba::post_data(con = con,
-                                data = raw_data_agri, #Nom de l'étape de laquelle est produit la lecture des données
-                                schema = "public",
-                                table = "agri",
-                                overwrite = TRUE)
-    ),
+      datalibaba::post_data_pg(data = raw_data_agri,  #Nom de l'étape de laquelle est produit la lecture des données
+                               table = "agri", schema = "public", db = "datamart", user = "does", overwrite = TRUE)),
     tar_target(
       cogifier_agri,#Nom de l'étape
-      cogifier(raw_data_agri, #Nom de l'étape de laquelle est produit la lecture des données
-               code_commune = depcom),
+      cogifier_mil(raw_data_agri, #Nom de l'étape de laquelle est produit la lecture des données
+                  code_commune = depcom, mil = mil_cog),
       format = "feather" # Requires that the return value is a data frame
     ),
     tar_target(
       post_cogifier_agri, #Nom de l'étape
-      datalibaba::post_data(con = con,
-                                data = cogifier_agri, #Nom de l'étape de laquelle est produit la lecture des données
-                                schema = "public",
-                                table = "cogifiee_agri",
-                                overwrite = TRUE)
+      datalibaba::post_data_pg(data = cogifier_agri, #Nom de l'étape de laquelle est produit la lecture des données
+                               table = "cogifiee_agri", schema = "public", db = "datamart", user = "does", overwrite = TRUE)
     ),
     tar_target(
       raw_data_file_ecln, #Nom de l'étape
@@ -58,24 +51,18 @@ list(
     ),
     tar_target(
       post_ecln, #Nom de l'étape
-      datalibaba::post_data(con = con,
-                                data = raw_data_ecln, #Nom de l'étape de laquelle est produit la lecture des données
-                                schema = "public",
-                                table = "ecln",
-                                overwrite = TRUE)
+      datalibaba::post_data_pg(data = raw_data_ecln, #Nom de l'étape de laquelle est produit la lecture des données
+                               table = "ecln", schema = "public", db = "datamart", user = "does", overwrite = TRUE)
     ),
     tar_target(
       cogifier_ecln, #Nom de l'étape
-      cogifier(raw_data_ecln, #Nom de l'étape de laquelle est produit la lecture des données
-               code_commune = depcom),
+      cogifier_mil(raw_data_ecln, #Nom de l'étape de laquelle est produit la lecture des données
+                   code_commune = depcom, mil = mil_cog),
       format = "feather" # Requires that the return value is a data frame
     ),
     tar_target(
-      post_cogifier_ecln,#Nom de l'étape
-      datalibaba::post_data(con = con,
-                                data = cogifier_ecln, #Nom de l'étape de laquelle est produit la lecture des données
-                                schema = "public",
-                                table = "cogifiee_ecln",
-                                overwrite = TRUE)
+      post_cogifier_ecln, #Nom de l'étape
+      datalibaba::post_data_pg(data = cogifier_ecln, #Nom de l'étape de laquelle est produit la lecture des données
+                               table = "cogifiee_ecln", schema = "public", db = "datamart", user = "does", overwrite = TRUE)
     )
 )