Skip to content

Commit 1d077e2

Browse files
authored
YQ-4868 fixed token auth for YDB external data source (#28330)
1 parent eb551db commit 1d077e2

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

ydb/core/kqp/ut/federated_query/datastreams/datastreams_ut.cpp

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -755,6 +755,7 @@ class TStreamingSysViewTestFixture : public TStreamingTestFixture {
755755
inline static constexpr char INPUT_TOPIC_NAME[] = "sysViewInput";
756756
inline static constexpr char OUTPUT_TOPIC_NAME[] = "sysViewOutput";
757757
inline static constexpr char PQ_SOURCE[] = "sysViewSourceName";
758+
inline static constexpr TDuration STATS_WAIT_DURATION = TDuration::Seconds(2);
758759

759760
public:
760761
void Setup() {
@@ -3021,7 +3022,7 @@ Y_UNIT_TEST_SUITE(KqpStreamingQueriesSysView) {
30213022
StartQuery("C");
30223023
StartQuery("D");
30233024
StartQuery("E");
3024-
Sleep(TDuration::Seconds(1));
3025+
Sleep(STATS_WAIT_DURATION);
30253026

30263027
CheckSysView({
30273028
{"A"}, {"B"}, {"C"}, {"D"}, {"E"}
@@ -3063,6 +3064,7 @@ Y_UNIT_TEST_SUITE(KqpStreamingQueriesSysView) {
30633064
StartQuery("B");
30643065
StartQuery("C");
30653066
StartQuery("D");
3067+
Sleep(STATS_WAIT_DURATION);
30663068

30673069
CheckSysView({
30683070
{"A"}, {"B"}, {"C"}, {"D"}
@@ -3116,7 +3118,7 @@ Y_UNIT_TEST_SUITE(KqpStreamingQueriesSysView) {
31163118
pqGateway->WaitWriteSession(OutputTopic)->ExpectMessage("test0");
31173119

31183120
{
3119-
Sleep(TDuration::Seconds(1));
3121+
Sleep(STATS_WAIT_DURATION);
31203122
const auto result = CheckSysView({{
31213123
.Name = queryName,
31223124
.Status = "RUNNING",
@@ -3412,6 +3414,7 @@ Y_UNIT_TEST_SUITE(KqpStreamingQueriesSysView) {
34123414
return count == 0;
34133415
});
34143416

3417+
Sleep(STATS_WAIT_DURATION);
34153418
CheckSysView(rows);
34163419
}
34173420
}

ydb/library/yql/providers/generic/actors/yql_generic_credentials_provider.cpp

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,8 +8,6 @@ namespace NYql::NDq {
88
TGenericCredentialsProvider::TGenericCredentialsProvider(
99
const TString& structuredTokenJSON,
1010
const ISecuredServiceAccountCredentialsFactory::TPtr& credentialsFactory) {
11-
Y_ENSURE(credentialsFactory, "CredentialsFactory is not initialized");
12-
1311
if (IsStructuredTokenJson(structuredTokenJSON)) {
1412
TStructuredTokenParser parser = CreateStructuredTokenParser(structuredTokenJSON);
1513
if (parser.HasBasicAuth()) {

0 commit comments

Comments
 (0)