Skip to content

Commit 9147579

Browse files
committed
refactor: clean up commented-out transform logic in replication test
1 parent f13188a commit 9147579

File tree

1 file changed

+0
-30
lines changed

1 file changed

+0
-30
lines changed

cmd/sling/tests/replications/r.87.record_key_casing_bigquery.yaml

Lines changed: 0 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -66,41 +66,11 @@ streams:
6666
mode: full-refresh
6767
target_options:
6868
direct_insert: true
69-
# transforms:
70-
# - true_changed_at: >
71-
# greatest(
72-
# cast(record.dateadded, "timestamp"),
73-
# cast(record.lastchanged, "timestamp"),
74-
# cast(record._sling_deleted_at, "timestamp")
75-
# )
76-
77-
# transforms:
78-
# - true_changed_at: >
79-
# greatest(
80-
# cast(replace(record.dateadded, "\"", ""), "timestamp"),
81-
# cast(replace(record.lastchanged, "\"", ""), "timestamp"),
82-
# cast(replace(record._sling_deleted_at, "\"", ""), "timestamp")
83-
# )
8469

8570
transforms:
86-
# - dateadded: log(greatest(record.dateadded, record.lastchanged))
87-
8871
- true_changed_at: >
8972
greatest(
9073
date_parse(record.dateadded),
9174
date_parse(record.lastchanged),
9275
date_parse(record._sling_deleted_at)
9376
)
94-
95-
# - true_changed_at: >
96-
# greatest(
97-
# date_parse(replace(record.dateadded, "\"", "")),
98-
# date_parse(replace(record.lastchanged, "\"", "")),
99-
# date_parse(replace(record._sling_deleted_at, "\"", ""))
100-
# )
101-
102-
# transforms:
103-
# - true_changed_at: >
104-
# date_parse(
105-
# greatest(record.dateadded, record.lastchanged. record._sling_deleted_at)
106-
# )

0 commit comments

Comments
 (0)