File tree 1 file changed +3
-3
lines changed
1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -962,7 +962,7 @@ def workflow_kafka_source_rehydration(c: Composition) -> None:
962
962
duration = time .time () - start_time
963
963
assert result [0 ][0 ] == count * repeats , f"Wrong result: { result } "
964
964
assert (
965
- duration < 2
965
+ duration < 4
966
966
), f"Took { duration } s to SELECT on Kafka source after 0dt upgrade, is it hydrated?"
967
967
968
968
@@ -1076,7 +1076,7 @@ def workflow_pg_source_rehydration(c: Composition) -> None:
1076
1076
duration = time .time () - start_time
1077
1077
assert result [0 ][0 ] == count * repeats , f"Wrong result: { result } "
1078
1078
assert (
1079
- duration < 2
1079
+ duration < 4
1080
1080
), f"Took { duration } s to SELECT on Postgres source after 0dt upgrade, is it hydrated?"
1081
1081
1082
1082
@@ -1191,7 +1191,7 @@ def workflow_mysql_source_rehydration(c: Composition) -> None:
1191
1191
duration = time .time () - start_time
1192
1192
assert result [0 ][0 ] == count * repeats , f"Wrong result: { result } "
1193
1193
assert (
1194
- duration < 2
1194
+ duration < 4
1195
1195
), f"Took { duration } s to SELECT on MySQL source after 0dt upgrade, is it hydrated?"
1196
1196
1197
1197
You can’t perform that action at this time.
0 commit comments