diff --git a/dal/sqlcgen/queries.sql.go b/dal/sqlcgen/queries.sql.go
index e1be252..0a7e074 100644
--- a/dal/sqlcgen/queries.sql.go
+++ b/dal/sqlcgen/queries.sql.go
@@ -173,12 +173,12 @@ WITH user_data AS (
     FROM users
     WHERE users.AccountID = $1
 ), new_fields AS (
-    SELECT (field->>'AmoID')::INT,
-    COALESCE(field->>'Code', '')::varchar(255),
-    COALESCE(field->>'Name', '')::varchar(50),
-    CAST(field->>'Entity' AS entitytype),
-    COALESCE(field->>'Type', '')::varchar(50),
-    CURRENT_TIMESTAMP
+    SELECT (field->>'AmoID')::INT AS amoID,
+    COALESCE(field->>'Code', '')::varchar(255) AS code,
+    COALESCE(field->>'Name', '')::varchar(50) AS name,
+    CAST(field->>'Entity' AS entitytype) AS Entity,
+    COALESCE(field->>'Type', '')::varchar(50) AS type,
+    CURRENT_TIMESTAMP AS createdAt
     FROM json_array_elements($2::json) AS field
 ), inserted_fields AS(
     INSERT INTO fields (amoID, code, accountID, name, Entity, type, createdAt)
@@ -188,7 +188,7 @@ WITH user_data AS (
                   nf.name,
                   nf.Entity,
                   nf.type,
-                  CURRENT_TIMESTAMP
+                  nf.createdAt
            FROM new_fields nf
                     JOIN user_data ud ON true
            ON CONFLICT (amoID, accountID, entity) DO NOTHING
@@ -249,11 +249,11 @@ func (q *Queries) CheckFields(ctx context.Context, arg CheckFieldsParams) ([]Che
 
 const checkPipelines = `-- name: CheckPipelines :many
 WITH new_pipelines AS (
-    SELECT (pipeline->>'AmoID')::INT,
-           (pipeline->>'AccountID')::INT,
-           COALESCE(pipeline->>'Name', '')::varchar(50),
-           CASE WHEN (pipeline->>'IsArchive') = 'true' THEN TRUE ELSE FALSE END,
-           CURRENT_TIMESTAMP
+    SELECT (pipeline->>'AmoID')::INT AS amoID,
+           (pipeline->>'AccountID')::INT AS accountID,
+           COALESCE(pipeline->>'Name', '')::varchar(50) AS name,
+           CASE WHEN (pipeline->>'IsArchive') = 'true' THEN TRUE ELSE FALSE END AS isArchive,
+           CURRENT_TIMESTAMP AS createdAt
     FROM json_array_elements($1::json) AS pipeline
 ), inserted_pipelines AS(
     INSERT INTO pipelines (amoID, accountID, name, isArchive, createdAt)
@@ -261,7 +261,7 @@ WITH new_pipelines AS (
                   np.accountID,
                   np.name,
                   np.isArchive,
-                  CURRENT_TIMESTAMP
+                  np.createdAt
            FROM new_pipelines np
            ON CONFLICT (amoID, accountID) DO NOTHING
            RETURNING id, amoid, accountid, name, isarchive, deleted, createdat
@@ -358,12 +358,12 @@ func (q *Queries) CheckResultsOwner(ctx context.Context, arg CheckResultsOwnerPa
 
 const checkSteps = `-- name: CheckSteps :many
 WITH new_steps AS (
-    SELECT (step->>'AmoID')::INT,
-           (step->>'PipelineID')::INT,
-           (step->>'AccountID')::INT,
-           COALESCE(step->>'Name', '')::varchar(50),
-           COALESCE(step->>'Color', '')::varchar(50),
-           CURRENT_TIMESTAMP
+    SELECT (step->>'AmoID')::INT AS amoID,
+           (step->>'PipelineID')::INT AS pipelineID,
+           (step->>'AccountID')::INT AS accountID,
+           COALESCE(step->>'Name', '')::varchar(50) AS name,
+           COALESCE(step->>'Color', '')::varchar(50) AS color,
+           CURRENT_TIMESTAMP AS createdAt
     FROM json_array_elements($1::json) AS step
 ), inserted_steps AS (
     INSERT INTO steps (amoID, pipelineID, accountID, name, color, createdAt)
@@ -372,7 +372,7 @@ WITH new_steps AS (
                   ns.accountID,
                   ns.name,
                   ns.color,
-                  CURRENT_TIMESTAMP
+                  ns.createdAt
            FROM new_steps ns
            ON CONFLICT (amoID, accountID, PipelineID) DO NOTHING
            RETURNING id, amoid, pipelineid, accountid, name, color, deleted, createdat