|
| 1 | +#include <ydb/core/kqp/federated_query/kqp_federated_query_helpers.h> |
1 | 2 | #include <ydb/core/kqp/ut/common/kqp_ut_common.h> |
2 | 3 | #include <ydb/core/kqp/ut/federated_query/common/common.h> |
3 | | -#include <ydb/core/kqp/federated_query/kqp_federated_query_helpers.h> |
| 4 | +#include <ydb/library/yql/providers/s3/actors/yql_s3_actors_factory_impl.h> |
4 | 5 | #include <ydb/library/yql/utils/log/log.h> |
5 | 6 | #include <ydb/public/sdk/cpp/client/draft/ydb_scripting.h> |
6 | 7 | #include <ydb/public/sdk/cpp/client/ydb_operation/operation.h> |
7 | 8 | #include <ydb/public/sdk/cpp/client/ydb_proto/accessor.h> |
8 | | -#include <ydb/public/sdk/cpp/client/ydb_types/operation/operation.h> |
9 | 9 | #include <ydb/public/sdk/cpp/client/ydb_table/table.h> |
| 10 | +#include <ydb/public/sdk/cpp/client/ydb_types/operation/operation.h> |
10 | 11 |
|
11 | 12 | #include <library/cpp/testing/unittest/registar.h> |
12 | 13 |
|
@@ -38,15 +39,16 @@ TString Exec(const TString& cmd) { |
38 | 39 |
|
39 | 40 | TString GetExternalPort(const TString& service, const TString& port) { |
40 | 41 | auto dockerComposeBin = BinaryPath("library/recipes/docker_compose/bin/docker-compose"); |
41 | | - auto composeFileYml = ArcadiaSourceRoot() + "/ydb/core/external_sources/s3/ut/docker-compose.yml"; |
| 42 | + auto composeFileYml = ArcadiaFromCurrentLocation(__SOURCE_FILE__, "docker-compose.yml"); |
42 | 43 | auto result = StringSplitter(Exec(dockerComposeBin + " -f " + composeFileYml + " port " + service + " " + port)).Split(':').ToList<TString>(); |
43 | 44 | return result ? Strip(result.back()) : TString{}; |
44 | 45 | } |
45 | 46 |
|
46 | 47 | Y_UNIT_TEST_SUITE(S3AwsCredentials) { |
47 | 48 | Y_UNIT_TEST(ExecuteScriptWithEqSymbol) { |
48 | 49 | const TString externalDataSourceName = "/Root/external_data_source"; |
49 | | - auto kikimr = MakeKikimrRunner(true); |
| 50 | + auto s3ActorsFactory = NYql::NDq::CreateS3ActorsFactory(); |
| 51 | + auto kikimr = MakeKikimrRunner(true, nullptr, nullptr, std::nullopt, s3ActorsFactory); |
50 | 52 | auto tc = kikimr->GetTableClient(); |
51 | 53 | auto session = tc.CreateSession().GetValueSync().GetSession(); |
52 | 54 | const TString query = fmt::format(R"( |
|
0 commit comments