From b1f681e2fef93cfe5c0ce809d82f24a11d188b93 Mon Sep 17 00:00:00 2001 From: Hor911 Date: Sat, 10 Feb 2024 21:11:56 +0300 Subject: [PATCH] Break deps from core/grpc_services to core/fq/libs/actors (#1781) * Break deps from core/grpc_services to core/fq/libs/actors * Delete random files * Restore old version --- ydb/core/fq/libs/actors/proxy_private.h | 2 -- .../fq/libs/control_plane_proxy/control_plane_proxy.cpp | 2 +- ydb/core/fq/libs/control_plane_proxy/events/events.h | 2 ++ ydb/core/fq/libs/control_plane_proxy/{ => utils}/utils.h | 0 ydb/core/fq/libs/control_plane_proxy/utils/ya.make | 9 +++++++++ ydb/core/fq/libs/control_plane_proxy/ya.make | 1 + ydb/core/fq/libs/events/events.h | 2 ++ ydb/core/grpc_services/rpc_fq.cpp | 3 +-- ydb/core/grpc_services/rpc_fq_internal.cpp | 1 - ydb/core/grpc_services/service_fq.h | 2 +- ydb/core/grpc_services/ya.make | 3 +-- ydb/core/kqp/executer_actor/ya.make | 1 + ydb/core/kqp/node_service/ya.make | 1 + 13 files changed, 20 insertions(+), 9 deletions(-) rename ydb/core/fq/libs/control_plane_proxy/{ => utils}/utils.h (100%) create mode 100644 ydb/core/fq/libs/control_plane_proxy/utils/ya.make diff --git a/ydb/core/fq/libs/actors/proxy_private.h b/ydb/core/fq/libs/actors/proxy_private.h index 4be79ef3277f..9a55b8a513ba 100644 --- a/ydb/core/fq/libs/actors/proxy_private.h +++ b/ydb/core/fq/libs/actors/proxy_private.h @@ -22,8 +22,6 @@ namespace NKikimr { namespace NFq { -NActors::TActorId MakeYqPrivateProxyId(); - NActors::IActor* CreateYqlAnalyticsPrivateProxy( const NConfig::TPrivateProxyConfig& privateProxyConfig, TIntrusivePtr timeProvider, diff --git a/ydb/core/fq/libs/control_plane_proxy/control_plane_proxy.cpp b/ydb/core/fq/libs/control_plane_proxy/control_plane_proxy.cpp index 1ddbb70aa802..66dd314978c9 100644 --- a/ydb/core/fq/libs/control_plane_proxy/control_plane_proxy.cpp +++ b/ydb/core/fq/libs/control_plane_proxy/control_plane_proxy.cpp @@ -1,7 +1,6 @@ #include "config.h" #include "control_plane_proxy.h" #include "probes.h" -#include "utils.h" #include #include @@ -23,6 +22,7 @@ #include #include #include +#include #include #include diff --git a/ydb/core/fq/libs/control_plane_proxy/events/events.h b/ydb/core/fq/libs/control_plane_proxy/events/events.h index 397a43a3a8ee..46091413dae6 100644 --- a/ydb/core/fq/libs/control_plane_proxy/events/events.h +++ b/ydb/core/fq/libs/control_plane_proxy/events/events.h @@ -394,4 +394,6 @@ struct TEvControlPlaneProxy { }; }; +NActors::TActorId ControlPlaneProxyActorId(); + } diff --git a/ydb/core/fq/libs/control_plane_proxy/utils.h b/ydb/core/fq/libs/control_plane_proxy/utils/utils.h similarity index 100% rename from ydb/core/fq/libs/control_plane_proxy/utils.h rename to ydb/core/fq/libs/control_plane_proxy/utils/utils.h diff --git a/ydb/core/fq/libs/control_plane_proxy/utils/ya.make b/ydb/core/fq/libs/control_plane_proxy/utils/ya.make new file mode 100644 index 000000000000..9fe9e6e570bf --- /dev/null +++ b/ydb/core/fq/libs/control_plane_proxy/utils/ya.make @@ -0,0 +1,9 @@ +LIBRARY() + +PEERDIR( + ydb/public/api/protos +) + +YQL_LAST_ABI_VERSION() + +END() diff --git a/ydb/core/fq/libs/control_plane_proxy/ya.make b/ydb/core/fq/libs/control_plane_proxy/ya.make index 4bd32ad74c0c..bb6fe225efa7 100644 --- a/ydb/core/fq/libs/control_plane_proxy/ya.make +++ b/ydb/core/fq/libs/control_plane_proxy/ya.make @@ -33,6 +33,7 @@ END() RECURSE( actors events + utils ) RECURSE_FOR_TESTS( diff --git a/ydb/core/fq/libs/events/events.h b/ydb/core/fq/libs/events/events.h index e0a84beb4d4c..73fa33dc4d6d 100644 --- a/ydb/core/fq/libs/events/events.h +++ b/ydb/core/fq/libs/events/events.h @@ -250,6 +250,8 @@ struct TEvents { }; }; +NActors::TActorId MakeYqPrivateProxyId(); + } // namespace NFq template<> diff --git a/ydb/core/grpc_services/rpc_fq.cpp b/ydb/core/grpc_services/rpc_fq.cpp index 49701c1b80b6..8d165726f340 100644 --- a/ydb/core/grpc_services/rpc_fq.cpp +++ b/ydb/core/grpc_services/rpc_fq.cpp @@ -4,9 +4,8 @@ #include #include #include -#include #include -#include +#include #include #include diff --git a/ydb/core/grpc_services/rpc_fq_internal.cpp b/ydb/core/grpc_services/rpc_fq_internal.cpp index 96dd18b34492..02c80ba4d125 100644 --- a/ydb/core/grpc_services/rpc_fq_internal.cpp +++ b/ydb/core/grpc_services/rpc_fq_internal.cpp @@ -3,7 +3,6 @@ #include "rpc_deferrable.h" #include -#include #include #include diff --git a/ydb/core/grpc_services/service_fq.h b/ydb/core/grpc_services/service_fq.h index f632bb2ee9cc..85b226f8ea02 100644 --- a/ydb/core/grpc_services/service_fq.h +++ b/ydb/core/grpc_services/service_fq.h @@ -4,7 +4,7 @@ #include #include -#include +#include namespace NKikimr { namespace NGRpcService { diff --git a/ydb/core/grpc_services/ya.make b/ydb/core/grpc_services/ya.make index c3fd88321a38..6af54cac7e44 100644 --- a/ydb/core/grpc_services/ya.make +++ b/ydb/core/grpc_services/ya.make @@ -95,8 +95,7 @@ PEERDIR( ydb/core/discovery ydb/core/engine ydb/core/formats - ydb/core/fq/libs/actors - ydb/core/fq/libs/control_plane_proxy + ydb/core/fq/libs/events ydb/core/fq/libs/control_plane_proxy/events ydb/core/grpc_services/base ydb/core/grpc_services/counters diff --git a/ydb/core/kqp/executer_actor/ya.make b/ydb/core/kqp/executer_actor/ya.make index 7a7cee3e675e..69b82aca80aa 100644 --- a/ydb/core/kqp/executer_actor/ya.make +++ b/ydb/core/kqp/executer_actor/ya.make @@ -26,6 +26,7 @@ PEERDIR( ydb/core/client/minikql_compile ydb/core/formats ydb/core/kqp/common + ydb/core/kqp/compute_actor ydb/core/kqp/query_compiler ydb/core/kqp/rm_service ydb/core/kqp/topics diff --git a/ydb/core/kqp/node_service/ya.make b/ydb/core/kqp/node_service/ya.make index 7dc91a19f358..8ffe88e4925e 100644 --- a/ydb/core/kqp/node_service/ya.make +++ b/ydb/core/kqp/node_service/ya.make @@ -10,6 +10,7 @@ PEERDIR( ydb/core/base ydb/core/cms/console ydb/core/kqp/common + ydb/core/kqp/compute_actor ydb/core/kqp/counters ydb/core/mind ydb/core/protos