You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
16 def _write_starting_replication_value(self, context: Optional[dict]) -> None:
15 """Write the starting replication value, if available.
14
13 Args:
12 context: Stream partition or context dictionary.
11 """
10 value = None
9 state = self.get_context_state(context)
8
7 if self.replication_key:
6 replication_key_value = state.get("replication_key_value")
5 if replication_key_value and self.replication_key == state.get(
4 "replication_key"
3 ):
2 value = replication_key_value
1
321 elif "start_date" in self.config:
1 value = self.config["start_date"]
2
3 write_starting_replication_value(state, value)
From the SDK brings in start_date, which means techincally if you pass in a unix timstamp for start_date it will work. We don't advertise this as the "standard" for start_date is to use an RFC3399 datetime type
Options
We could just override start_date's value with the timestamp value. right at the initialization of the tap.
Currently
From the SDK brings in start_date, which means techincally if you pass in a unix timstamp for start_date it will work. We don't advertise this as the "standard" for start_date is to use an RFC3399 datetime type
Options
Instead of figuring this out right now we're just not going to officially support start_date.
The text was updated successfully, but these errors were encountered: