BUILD.bazel 65 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721
  1. # Bazel build
  2. # C/C++ documentation: https://docs.bazel.build/versions/master/be/c-cpp.html
  3. # ************************** IMPORTANT ***********************
  4. # If a target or file is not found here, then please try searching in /src
  5. # We are in the middle of transitioning to a tree of build files.
  6. # If you would like to help with the move in your PR, please use `git mv` so that the history of the file is retained.
  7. load("@rules_proto//proto:defs.bzl", "proto_library")
  8. load("@rules_python//python:defs.bzl", "py_library", "py_runtime", "py_runtime_pair")
  9. load("@rules_cc//cc:defs.bzl", "cc_binary", "cc_library", "cc_proto_library", "cc_test")
  10. load("@com_github_grpc_grpc//bazel:cc_grpc_library.bzl", "cc_grpc_library")
  11. load("@com_github_grpc_grpc//bazel:cython_library.bzl", "pyx_library")
  12. load("@com_github_google_flatbuffers//:build_defs.bzl", "flatbuffer_cc_library")
  13. load("//bazel:ray.bzl", "COPTS", "PYX_COPTS", "PYX_SRCS", "copy_to_workspace")
  14. load("@python3_9//:defs.bzl", python39 = "interpreter")
  15. package(
  16. default_visibility = ["//visibility:public"],
  17. )
  18. # Hermetic python envionment, currently only used for CI infra and scripts.
  19. py_runtime(
  20. name = "python3_runtime",
  21. interpreter = python39,
  22. python_version = "PY3",
  23. visibility = ["//visibility:private"],
  24. )
  25. py_runtime_pair(
  26. name = "python_runtime_pair",
  27. py2_runtime = None,
  28. py3_runtime = ":python3_runtime",
  29. visibility = ["//visibility:private"],
  30. )
  31. constraint_setting(name = "hermetic")
  32. constraint_value(
  33. name = "hermetic_python",
  34. constraint_setting = ":hermetic",
  35. visibility = ["//visibility:public"],
  36. )
  37. toolchain(
  38. name = "python_toolchain",
  39. exec_compatible_with = [":hermetic_python"],
  40. toolchain = ":python_runtime_pair",
  41. toolchain_type = "@bazel_tools//tools/python:toolchain_type",
  42. )
  43. platform(
  44. name = "hermetic_python_platform",
  45. constraint_values = [":hermetic_python"],
  46. parents = ["@local_config_platform//:host"],
  47. visibility = ["//visibility:private"],
  48. )
  49. # C/C++ toolchain constraint configs.
  50. config_setting(
  51. name = "msvc-cl",
  52. flag_values = {"@bazel_tools//tools/cpp:compiler": "msvc-cl"},
  53. )
  54. config_setting(
  55. name = "clang-cl",
  56. flag_values = {"@bazel_tools//tools/cpp:compiler": "clang-cl"},
  57. )
  58. config_setting(
  59. name = "opt",
  60. values = {"compilation_mode": "opt"},
  61. )
  62. # === Begin of rpc definitions ===
  63. # GRPC common lib.
  64. cc_library(
  65. name = "grpc_common_lib",
  66. srcs = [
  67. "src/ray/rpc/common.cc",
  68. "src/ray/rpc/grpc_server.cc",
  69. "src/ray/rpc/server_call.cc",
  70. ],
  71. hdrs = glob([
  72. "src/ray/rpc/client_call.h",
  73. "src/ray/rpc/common.h",
  74. "src/ray/rpc/grpc_client.h",
  75. "src/ray/rpc/grpc_server.h",
  76. "src/ray/rpc/metrics_agent_client.h",
  77. "src/ray/rpc/server_call.h",
  78. "src/ray/rpc/grpc_util.h",
  79. "src/ray/raylet_client/*.h",
  80. ]),
  81. copts = COPTS,
  82. strip_include_prefix = "src",
  83. deps = [
  84. ":stats_metric",
  85. "//src/ray/common:asio",
  86. "//src/ray/common:grpc_util",
  87. "//src/ray/common:id",
  88. "//src/ray/common:status",
  89. "@com_github_grpc_grpc//:grpc++",
  90. "@com_github_grpc_grpc//:grpc++_reflection",
  91. "@com_github_grpc_grpc//:grpcpp_admin",
  92. "@com_google_protobuf//:protobuf",
  93. ],
  94. )
  95. # Node manager gRPC lib.
  96. cc_grpc_library(
  97. name = "node_manager_cc_grpc",
  98. srcs = ["//src/ray/protobuf:node_manager_proto"],
  99. grpc_only = True,
  100. deps = ["//src/ray/protobuf:node_manager_cc_proto"],
  101. )
  102. # Node manager server and client.
  103. cc_library(
  104. name = "node_manager_rpc",
  105. srcs = glob([
  106. "src/ray/rpc/node_manager/*.cc",
  107. ]),
  108. hdrs = glob([
  109. "src/ray/rpc/node_manager/*.h",
  110. ]),
  111. copts = COPTS,
  112. strip_include_prefix = "src",
  113. deps = [
  114. ":grpc_common_lib",
  115. ":node_manager_cc_grpc",
  116. ":ray_common",
  117. "@boost//:asio",
  118. "@com_github_grpc_grpc//:grpc++",
  119. ],
  120. )
  121. # gcs_service gRPC lib.
  122. cc_grpc_library(
  123. name = "gcs_service_cc_grpc",
  124. srcs = ["//src/ray/protobuf:gcs_service_proto"],
  125. grpc_only = True,
  126. deps = ["//src/ray/protobuf:gcs_service_cc_proto"],
  127. )
  128. # gcs_service gRPC lib.
  129. cc_grpc_library(
  130. name = "test_service_cc_grpc",
  131. srcs = ["//src/ray/protobuf:test_service_proto"],
  132. grpc_only = True,
  133. deps = ["//src/ray/protobuf:test_service_cc_proto"],
  134. )
  135. # gcs rpc server and client.
  136. cc_library(
  137. name = "gcs_service_rpc",
  138. hdrs = [
  139. "src/ray/rpc/gcs_server/gcs_rpc_client.h",
  140. "src/ray/rpc/gcs_server/gcs_rpc_server.h",
  141. ],
  142. copts = COPTS,
  143. strip_include_prefix = "src",
  144. deps = [
  145. ":autoscaler_cc_grpc",
  146. ":gcs_service_cc_grpc",
  147. ":grpc_common_lib",
  148. ":pubsub_lib",
  149. ":ray_common",
  150. "@boost//:asio",
  151. "@com_github_grpc_grpc//:grpc++",
  152. "@com_google_absl//absl/container:btree",
  153. ],
  154. )
  155. # Object manager gRPC lib.
  156. cc_grpc_library(
  157. name = "object_manager_cc_grpc",
  158. srcs = ["//src/ray/protobuf:object_manager_proto"],
  159. grpc_only = True,
  160. deps = ["//src/ray/protobuf:object_manager_cc_proto"],
  161. )
  162. # Object manager rpc server and client.
  163. cc_library(
  164. name = "object_manager_rpc",
  165. hdrs = glob([
  166. "src/ray/rpc/object_manager/*.h",
  167. ]),
  168. copts = COPTS,
  169. strip_include_prefix = "src",
  170. deps = [
  171. ":grpc_common_lib",
  172. ":object_manager_cc_grpc",
  173. ":ray_common",
  174. "@boost//:asio",
  175. "@com_github_grpc_grpc//:grpc++",
  176. ],
  177. )
  178. # Worker gRPC lib.
  179. cc_grpc_library(
  180. name = "worker_cc_grpc",
  181. srcs = ["//src/ray/protobuf:core_worker_proto"],
  182. grpc_only = True,
  183. deps = ["//src/ray/protobuf:worker_cc_proto"],
  184. )
  185. # worker server and client.
  186. cc_library(
  187. name = "worker_rpc",
  188. srcs = glob([
  189. "src/ray/rpc/worker/*.cc",
  190. ]),
  191. hdrs = glob([
  192. "src/ray/rpc/worker/*.h",
  193. ]),
  194. copts = COPTS,
  195. strip_include_prefix = "src",
  196. deps = [
  197. ":grpc_common_lib",
  198. ":pubsub_lib",
  199. ":ray_common",
  200. ":worker_cc_grpc",
  201. "@boost//:asio",
  202. "@boost//:thread",
  203. "@com_github_grpc_grpc//:grpc++",
  204. ],
  205. )
  206. # Metrics Agent gRPC lib.
  207. cc_grpc_library(
  208. name = "reporter_cc_grpc",
  209. srcs = ["//src/ray/protobuf:reporter_proto"],
  210. grpc_only = True,
  211. deps = ["//src/ray/protobuf:reporter_cc_proto"],
  212. )
  213. # Metrics Agent client.
  214. cc_library(
  215. name = "reporter_rpc",
  216. hdrs = glob([
  217. "src/ray/rpc/metrics_agent_client.h",
  218. ]),
  219. copts = COPTS,
  220. strip_include_prefix = "src",
  221. deps = [
  222. ":grpc_common_lib",
  223. ":reporter_cc_grpc",
  224. "//src/ray/common:status",
  225. "@boost//:asio",
  226. "@boost//:thread",
  227. "@com_github_grpc_grpc//:grpc++",
  228. ],
  229. )
  230. # pubsub.
  231. cc_grpc_library(
  232. name = "pubsub_cc_grpc",
  233. srcs = ["//src/ray/protobuf:pubsub_proto"],
  234. grpc_only = True,
  235. deps = [
  236. "//src/ray/protobuf:common_cc_proto",
  237. "//src/ray/protobuf:gcs_cc_proto",
  238. "//src/ray/protobuf:pubsub_cc_proto",
  239. ],
  240. )
  241. cc_library(
  242. name = "pubsub_rpc",
  243. copts = COPTS,
  244. deps = [
  245. "pubsub_cc_grpc",
  246. ":grpc_common_lib",
  247. ":ray_common",
  248. ],
  249. )
  250. # monitor/autoscaler service
  251. cc_grpc_library(
  252. name = "monitor_cc_grpc",
  253. srcs = ["//src/ray/protobuf:monitor_proto"],
  254. grpc_only = True,
  255. deps = ["//src/ray/protobuf:monitor_cc_proto"],
  256. )
  257. cc_library(
  258. name = "monitor_rpc",
  259. copts = COPTS,
  260. visibility = ["//visibility:public"],
  261. deps = [
  262. ":monitor_cc_grpc",
  263. ],
  264. )
  265. cc_grpc_library(
  266. name = "autoscaler_cc_grpc",
  267. srcs = ["//src/ray/protobuf:autoscaler_proto"],
  268. grpc_only = True,
  269. deps = [
  270. "//src/ray/protobuf:autoscaler_cc_proto",
  271. ],
  272. )
  273. cc_library(
  274. name = "autoscaler_rpc",
  275. copts = COPTS,
  276. visibility = ["//visibility:public"],
  277. deps = [
  278. ":autoscaler_cc_grpc",
  279. ],
  280. )
  281. # === End of rpc definitions ===
  282. # === Begin of plasma definitions ===
  283. # TODO(mehrdadn): (How to) support dynamic linking?
  284. PROPAGATED_WINDOWS_DEFINES = ["ARROW_STATIC"]
  285. PLASMA_COPTS = COPTS + select({
  286. "@bazel_tools//src/conditions:windows": [
  287. ] + ["-D" + define for define in PROPAGATED_WINDOWS_DEFINES],
  288. "//conditions:default": [
  289. "-DARROW_USE_GLOG",
  290. ],
  291. })
  292. PLASMA_LINKOPTS = [] + select({
  293. "@bazel_tools//src/conditions:windows": [
  294. "-DefaultLib:" + "ws2_32.lib",
  295. ],
  296. "//conditions:default": [
  297. ],
  298. })
  299. cc_library(
  300. name = "plasma_client",
  301. srcs = [
  302. "src/ray/object_manager/plasma/client.cc",
  303. "src/ray/object_manager/plasma/connection.cc",
  304. "src/ray/object_manager/plasma/malloc.cc",
  305. "src/ray/object_manager/plasma/plasma.cc",
  306. "src/ray/object_manager/plasma/protocol.cc",
  307. "src/ray/object_manager/plasma/shared_memory.cc",
  308. ] + select({
  309. "@bazel_tools//src/conditions:windows": [
  310. ],
  311. "//conditions:default": [
  312. "src/ray/object_manager/plasma/fling.cc",
  313. ],
  314. }),
  315. hdrs = [
  316. "src/ray/object_manager/common.h",
  317. "src/ray/object_manager/plasma/client.h",
  318. "src/ray/object_manager/plasma/common.h",
  319. "src/ray/object_manager/plasma/compat.h",
  320. "src/ray/object_manager/plasma/connection.h",
  321. "src/ray/object_manager/plasma/malloc.h",
  322. "src/ray/object_manager/plasma/plasma.h",
  323. "src/ray/object_manager/plasma/plasma_generated.h",
  324. "src/ray/object_manager/plasma/protocol.h",
  325. "src/ray/object_manager/plasma/shared_memory.h",
  326. ] + select({
  327. "@bazel_tools//src/conditions:windows": [
  328. ],
  329. "//conditions:default": [
  330. "src/ray/object_manager/plasma/fling.h",
  331. ],
  332. }),
  333. copts = PLASMA_COPTS,
  334. defines = select({
  335. "@bazel_tools//src/conditions:windows": PROPAGATED_WINDOWS_DEFINES,
  336. "//conditions:default": [],
  337. }),
  338. linkopts = PLASMA_LINKOPTS,
  339. strip_include_prefix = "src",
  340. deps = [
  341. ":plasma_fbs",
  342. ":ray_common",
  343. "//src/ray/protobuf:common_cc_proto",
  344. "//src/ray/util",
  345. "@msgpack",
  346. ],
  347. )
  348. cc_library(
  349. name = "plasma_store_server_lib",
  350. srcs = [
  351. "src/ray/object_manager/plasma/create_request_queue.cc",
  352. "src/ray/object_manager/plasma/dlmalloc.cc",
  353. "src/ray/object_manager/plasma/eviction_policy.cc",
  354. "src/ray/object_manager/plasma/get_request_queue.cc",
  355. "src/ray/object_manager/plasma/object_lifecycle_manager.cc",
  356. "src/ray/object_manager/plasma/object_store.cc",
  357. "src/ray/object_manager/plasma/plasma_allocator.cc",
  358. "src/ray/object_manager/plasma/stats_collector.cc",
  359. "src/ray/object_manager/plasma/store.cc",
  360. "src/ray/object_manager/plasma/store_runner.cc",
  361. ],
  362. hdrs = [
  363. "src/ray/object_manager/common.h",
  364. "src/ray/object_manager/plasma/allocator.h",
  365. "src/ray/object_manager/plasma/create_request_queue.h",
  366. "src/ray/object_manager/plasma/eviction_policy.h",
  367. "src/ray/object_manager/plasma/get_request_queue.h",
  368. "src/ray/object_manager/plasma/object_lifecycle_manager.h",
  369. "src/ray/object_manager/plasma/object_store.h",
  370. "src/ray/object_manager/plasma/plasma_allocator.h",
  371. "src/ray/object_manager/plasma/stats_collector.h",
  372. "src/ray/object_manager/plasma/store.h",
  373. "src/ray/object_manager/plasma/store_runner.h",
  374. "src/ray/thirdparty/dlmalloc.c",
  375. ],
  376. copts = PLASMA_COPTS,
  377. linkopts = PLASMA_LINKOPTS,
  378. strip_include_prefix = "src",
  379. deps = [
  380. ":plasma_client",
  381. ":stats_lib",
  382. ],
  383. )
  384. FLATC_ARGS = [
  385. "--gen-object-api",
  386. "--gen-mutable",
  387. "--scoped-enums",
  388. ]
  389. flatbuffer_cc_library(
  390. name = "plasma_fbs",
  391. srcs = ["src/ray/object_manager/plasma/plasma.fbs"],
  392. flatc_args = FLATC_ARGS,
  393. out_prefix = "src/ray/object_manager/plasma/",
  394. )
  395. # === End of plasma definitions ===
  396. cc_library(
  397. name = "ray_mock",
  398. hdrs = glob(
  399. ["src/mock/**/*.h"],
  400. ),
  401. copts = COPTS,
  402. strip_include_prefix = "src",
  403. visibility = ["//visibility:public"],
  404. )
  405. cc_grpc_library(
  406. name = "ray_syncer_cc_grpc",
  407. srcs = ["//src/ray/protobuf:ray_syncer_proto"],
  408. grpc_only = True,
  409. deps = ["//src/ray/protobuf:ray_syncer_cc_proto"],
  410. )
  411. cc_library(
  412. name = "ray_common",
  413. copts = COPTS,
  414. strip_include_prefix = "src",
  415. visibility = ["//visibility:public"],
  416. deps = [
  417. ":stats_metric",
  418. "//src/ray/common:asio",
  419. "//src/ray/common:constants",
  420. "//src/ray/common:event_stats",
  421. "//src/ray/common:file_system_monitor",
  422. "//src/ray/common:grpc_util",
  423. "//src/ray/common:id",
  424. "//src/ray/common:memory_monitor",
  425. "//src/ray/common:network",
  426. "//src/ray/common:ray_config",
  427. "//src/ray/common:ray_syncer",
  428. "//src/ray/common:status",
  429. "//src/ray/common:task_common",
  430. "//src/ray/common:test_util",
  431. "//src/ray/protobuf:gcs_cc_proto",
  432. "@com_google_googletest//:gtest",
  433. ],
  434. )
  435. cc_binary(
  436. name = "raylet",
  437. srcs = ["src/ray/raylet/main.cc"],
  438. copts = COPTS,
  439. visibility = ["//java:__subpackages__"],
  440. deps = [
  441. ":raylet_lib",
  442. "//src/ray/util",
  443. "@com_github_gflags_gflags//:gflags",
  444. ],
  445. )
  446. cc_library(
  447. name = "gcs_pub_sub_lib",
  448. srcs = [
  449. "src/ray/gcs/pubsub/gcs_pub_sub.cc",
  450. ],
  451. hdrs = [
  452. "src/ray/gcs/pubsub/gcs_pub_sub.h",
  453. ],
  454. copts = COPTS,
  455. strip_include_prefix = "src",
  456. deps = [
  457. ":gcs",
  458. ":gcs_service_rpc",
  459. ":pubsub_lib",
  460. ":ray_common",
  461. ":redis_client",
  462. ],
  463. )
  464. cc_library(
  465. name = "gcs_server_lib",
  466. srcs = glob(
  467. [
  468. "src/ray/gcs/gcs_server/*.cc",
  469. ],
  470. exclude = [
  471. "src/ray/gcs/gcs_server/gcs_server_main.cc",
  472. "src/ray/gcs/gcs_server/test/*.cc",
  473. ],
  474. ),
  475. hdrs = glob(
  476. [
  477. "src/ray/gcs/gcs_server/*.h",
  478. ],
  479. ),
  480. copts = COPTS,
  481. strip_include_prefix = "src",
  482. deps = [
  483. ":autoscaler_rpc",
  484. ":gcs",
  485. ":gcs_pub_sub_lib",
  486. ":gcs_service_cc_grpc",
  487. ":gcs_service_rpc",
  488. ":gcs_table_storage_lib",
  489. ":monitor_rpc",
  490. ":node_manager_rpc",
  491. ":observable_store_client",
  492. ":pubsub_lib",
  493. ":raylet_client_lib",
  494. ":scheduler",
  495. ":worker_rpc",
  496. "//src/ray/protobuf:agent_manager_cc_proto",
  497. "@boost//:bimap",
  498. "@com_github_grpc_grpc//src/proto/grpc/health/v1:health_proto",
  499. "@com_google_absl//absl/container:btree",
  500. ],
  501. )
  502. cc_binary(
  503. name = "gcs_server",
  504. srcs = [
  505. "src/ray/gcs/gcs_server/gcs_server_main.cc",
  506. ],
  507. copts = COPTS,
  508. visibility = ["//java:__subpackages__"],
  509. deps = [
  510. ":gcs_server_lib",
  511. ":stats_lib",
  512. "@com_github_gflags_gflags//:gflags",
  513. ],
  514. )
  515. # Ray native pubsub module.
  516. cc_library(
  517. name = "pubsub_lib",
  518. srcs = glob([
  519. "src/ray/pubsub/*.cc",
  520. ]),
  521. hdrs = glob([
  522. "src/ray/pubsub/*.h",
  523. ]),
  524. copts = COPTS,
  525. strip_include_prefix = "src",
  526. visibility = ["//visibility:public"],
  527. deps = [
  528. ":pubsub_rpc",
  529. "@boost//:any",
  530. "@com_google_absl//absl/container:flat_hash_map",
  531. "@com_google_absl//absl/container:flat_hash_set",
  532. "@com_google_absl//absl/synchronization",
  533. ],
  534. )
  535. cc_library(
  536. name = "stats_metric",
  537. srcs = [
  538. "src/ray/stats/metric.cc",
  539. "src/ray/stats/metric_defs.cc",
  540. "src/ray/stats/tag_defs.cc",
  541. ],
  542. hdrs = [
  543. "src/ray/stats/metric.h",
  544. "src/ray/stats/metric_defs.h",
  545. "src/ray/stats/tag_defs.h",
  546. ],
  547. strip_include_prefix = "src",
  548. visibility = ["//visibility:public"],
  549. deps = [
  550. "//src/ray/util",
  551. "@com_github_jupp0r_prometheus_cpp//pull",
  552. "@com_google_absl//absl/base:core_headers",
  553. "@com_google_absl//absl/container:flat_hash_map",
  554. "@com_google_absl//absl/memory",
  555. "@com_google_absl//absl/strings",
  556. "@com_google_googletest//:gtest",
  557. "@io_opencensus_cpp//opencensus/exporters/stats/prometheus:prometheus_exporter",
  558. "@io_opencensus_cpp//opencensus/exporters/stats/stdout:stdout_exporter",
  559. "@io_opencensus_cpp//opencensus/stats",
  560. "@io_opencensus_cpp//opencensus/tags",
  561. ],
  562. )
  563. cc_library(
  564. name = "stats_lib",
  565. srcs = [
  566. "src/ray/stats/metric_exporter.cc",
  567. "src/ray/stats/metric_exporter_client.cc",
  568. ],
  569. hdrs = [
  570. "src/ray/stats/metric.h",
  571. "src/ray/stats/metric_exporter.h",
  572. "src/ray/stats/metric_exporter_client.h",
  573. "src/ray/stats/stats.h",
  574. "src/ray/stats/tag_defs.h",
  575. ],
  576. copts = COPTS,
  577. linkopts = select({
  578. "@bazel_tools//src/conditions:windows": [
  579. ],
  580. "//conditions:default": [
  581. "-lpthread",
  582. ],
  583. }),
  584. strip_include_prefix = "src",
  585. visibility = ["//visibility:public"],
  586. deps = [
  587. ":reporter_rpc",
  588. ":stats_metric",
  589. ],
  590. )
  591. cc_library(
  592. name = "scheduler",
  593. srcs = glob(
  594. [
  595. "src/ray/raylet/scheduling/**/*.cc",
  596. ],
  597. exclude = [
  598. "src/ray/raylet/scheduling/**/*_test.cc",
  599. ],
  600. ),
  601. hdrs = glob(
  602. [
  603. "src/ray/raylet/scheduling/**/*.h",
  604. "src/ray/core_worker/common.h",
  605. ],
  606. ),
  607. copts = COPTS,
  608. linkopts = select({
  609. "@bazel_tools//src/conditions:windows": [
  610. ],
  611. "//conditions:default": [
  612. "-lpthread",
  613. ],
  614. }),
  615. strip_include_prefix = "src",
  616. visibility = ["//visibility:public"],
  617. deps = [
  618. ":gcs_client_lib",
  619. ":ray_common",
  620. ":stats_lib",
  621. "//src/ray/protobuf:common_cc_proto",
  622. "//src/ray/util",
  623. "@boost//:asio",
  624. "@boost//:system",
  625. "@com_github_jupp0r_prometheus_cpp//pull",
  626. "@com_google_absl//absl/base:core_headers",
  627. "@com_google_absl//absl/container:flat_hash_set",
  628. "@com_google_absl//absl/memory",
  629. "@com_google_absl//absl/random",
  630. "@com_google_absl//absl/random:bit_gen_ref",
  631. "@com_google_absl//absl/strings",
  632. "@com_google_googletest//:gtest",
  633. "@io_opencensus_cpp//opencensus/exporters/stats/prometheus:prometheus_exporter",
  634. "@io_opencensus_cpp//opencensus/stats",
  635. "@io_opencensus_cpp//opencensus/tags",
  636. ],
  637. )
  638. cc_library(
  639. name = "raylet_lib",
  640. srcs = glob(
  641. [
  642. "src/ray/raylet/**/*.cc",
  643. ],
  644. exclude = [
  645. "src/ray/raylet/**/*_test.cc",
  646. "src/ray/raylet/scheduling/**/*.cc",
  647. "src/ray/raylet/main.cc",
  648. ],
  649. ),
  650. hdrs = glob(
  651. [
  652. "src/ray/raylet/**/*.h",
  653. ],
  654. exclude = [
  655. "src/ray/raylet/scheduling/**/*.h",
  656. "src/ray/raylet/main.cc",
  657. ],
  658. ),
  659. copts = COPTS,
  660. linkopts = select({
  661. "@bazel_tools//src/conditions:windows": [
  662. ],
  663. "//conditions:default": [
  664. "-lpthread",
  665. ],
  666. }),
  667. strip_include_prefix = "src",
  668. visibility = ["//visibility:public"],
  669. deps = [
  670. ":gcs",
  671. ":gcs_client_lib",
  672. ":node_manager_fbs",
  673. ":node_manager_rpc",
  674. ":object_manager",
  675. ":plasma_client",
  676. ":pubsub_lib",
  677. ":ray_common",
  678. ":scheduler",
  679. ":stats_lib",
  680. ":worker_rpc",
  681. "//src/ray/protobuf:agent_manager_cc_proto",
  682. "//src/ray/protobuf:common_cc_proto",
  683. "//src/ray/protobuf:runtime_env_agent_cc_proto",
  684. "//src/ray/util",
  685. "@boost//:asio",
  686. "@boost//:beast",
  687. "@boost//:system",
  688. "@com_github_jupp0r_prometheus_cpp//pull",
  689. "@com_google_absl//absl/base:core_headers",
  690. "@com_google_absl//absl/container:flat_hash_set",
  691. "@com_google_absl//absl/memory",
  692. "@com_google_absl//absl/strings",
  693. "@com_google_googletest//:gtest",
  694. "@io_opencensus_cpp//opencensus/exporters/stats/prometheus:prometheus_exporter",
  695. "@io_opencensus_cpp//opencensus/stats",
  696. "@io_opencensus_cpp//opencensus/tags",
  697. ],
  698. )
  699. cc_library(
  700. name = "raylet_client_lib",
  701. srcs = glob([
  702. "src/ray/raylet_client/*.cc",
  703. ]),
  704. hdrs = glob([
  705. "src/ray/raylet_client/*.h",
  706. ]),
  707. copts = COPTS,
  708. linkopts = select({
  709. "@bazel_tools//src/conditions:windows": [
  710. ],
  711. "//conditions:default": [
  712. "-lpthread",
  713. ],
  714. }),
  715. strip_include_prefix = "src",
  716. visibility = ["//visibility:public"],
  717. deps = [
  718. ":node_manager_fbs",
  719. ":node_manager_rpc",
  720. ":ray_common",
  721. "//src/ray/protobuf:gcs_cc_proto",
  722. "//src/ray/util",
  723. "@boost//:asio",
  724. ],
  725. )
  726. cc_library(
  727. name = "core_worker_lib",
  728. srcs = glob(
  729. [
  730. "src/ray/core_worker/*.cc",
  731. "src/ray/core_worker/store_provider/*.cc",
  732. "src/ray/core_worker/store_provider/memory_store/*.cc",
  733. "src/ray/core_worker/transport/*.cc",
  734. ],
  735. exclude = [
  736. "src/ray/core_worker/**/*_test.cc",
  737. "src/ray/core_worker/mock_worker.cc",
  738. ],
  739. ),
  740. hdrs = glob([
  741. "src/ray/core_worker/*.h",
  742. "src/ray/core_worker/store_provider/*.h",
  743. "src/ray/core_worker/store_provider/memory_store/*.h",
  744. "src/ray/core_worker/transport/*.h",
  745. ]),
  746. copts = COPTS,
  747. strip_include_prefix = "src",
  748. visibility = ["//visibility:public"],
  749. deps = [
  750. ":gcs",
  751. ":gcs_client_lib",
  752. ":plasma_client",
  753. ":ray_common",
  754. ":raylet_client_lib",
  755. ":stats_lib",
  756. ":worker_rpc",
  757. "//src/ray/protobuf:worker_cc_proto",
  758. "//src/ray/util",
  759. "@boost//:circular_buffer",
  760. "@boost//:fiber",
  761. "@com_google_absl//absl/cleanup",
  762. "@com_google_absl//absl/container:btree",
  763. "@com_google_absl//absl/container:flat_hash_map",
  764. "@com_google_absl//absl/container:flat_hash_set",
  765. "@nlohmann_json",
  766. ],
  767. )
  768. cc_library(
  769. name = "mock_worker_lib",
  770. srcs = ["src/ray/core_worker/test/mock_worker.cc"],
  771. hdrs = glob([
  772. "src/ray/core_worker/test/*.h",
  773. ]),
  774. copts = COPTS,
  775. strip_include_prefix = "src",
  776. deps = [
  777. ":core_worker_lib",
  778. ],
  779. )
  780. cc_binary(
  781. name = "mock_worker",
  782. copts = COPTS,
  783. deps = [
  784. ":mock_worker_lib",
  785. ],
  786. )
  787. cc_test(
  788. name = "core_worker_test",
  789. size = "small",
  790. srcs = ["src/ray/core_worker/test/core_worker_test.cc"],
  791. args = [
  792. "$(location raylet)",
  793. "$(location mock_worker)",
  794. "$(location gcs_server)",
  795. "$(location redis-cli)",
  796. "$(location redis-server)",
  797. ],
  798. copts = COPTS,
  799. data = [
  800. "//:gcs_server",
  801. "//:mock_worker",
  802. "//:raylet",
  803. "//:redis-cli",
  804. "//:redis-server",
  805. ],
  806. tags = ["team:core"],
  807. deps = [
  808. ":core_worker_lib",
  809. ":gcs",
  810. "//src/ray/protobuf:runtime_env_common_cc_proto",
  811. "@com_google_absl//absl/container:flat_hash_map",
  812. "@com_google_absl//absl/container:flat_hash_set",
  813. "@com_google_googletest//:gtest",
  814. ],
  815. )
  816. cc_test(
  817. name = "core_worker_resubmit_queue_test",
  818. size = "small",
  819. srcs = ["src/ray/core_worker/test/core_worker_resubmit_queue_test.cc"],
  820. copts = COPTS,
  821. tags = ["team:core"],
  822. deps = [
  823. ":core_worker_lib",
  824. "@com_google_googletest//:gtest_main",
  825. ],
  826. )
  827. cc_test(
  828. name = "memory_store_test",
  829. size = "small",
  830. srcs = ["src/ray/core_worker/test/memory_store_test.cc"],
  831. copts = COPTS,
  832. tags = ["team:core"],
  833. deps = [
  834. ":core_worker_lib",
  835. "@com_google_googletest//:gtest_main",
  836. ],
  837. )
  838. cc_test(
  839. name = "direct_actor_transport_test",
  840. srcs = ["src/ray/core_worker/test/direct_actor_transport_test.cc"],
  841. copts = COPTS,
  842. tags = ["team:core"],
  843. deps = [
  844. ":core_worker_lib",
  845. ":ray_mock",
  846. "@com_google_googletest//:gtest_main",
  847. ],
  848. )
  849. cc_test(
  850. name = "direct_actor_transport_mock_test",
  851. srcs = ["src/ray/core_worker/test/direct_actor_transport_mock_test.cc"],
  852. copts = COPTS,
  853. tags = ["team:core"],
  854. deps = [
  855. ":core_worker_lib",
  856. ":ray_mock",
  857. "@com_google_googletest//:gtest_main",
  858. ],
  859. )
  860. cc_test(
  861. name = "gcs_function_manager_test",
  862. srcs = ["src/ray/gcs/gcs_server/test/gcs_function_manager_test.cc"],
  863. copts = COPTS,
  864. tags = ["team:core"],
  865. deps = [
  866. ":gcs_server_lib",
  867. ":ray_mock",
  868. "@com_google_googletest//:gtest_main",
  869. ],
  870. )
  871. cc_test(
  872. name = "dependency_resolver_test",
  873. size = "small",
  874. srcs = ["src/ray/core_worker/test/dependency_resolver_test.cc"],
  875. copts = COPTS,
  876. tags = ["team:core"],
  877. deps = [
  878. ":core_worker_lib",
  879. ":ray_mock",
  880. "@com_google_googletest//:gtest_main",
  881. ],
  882. )
  883. cc_test(
  884. name = "direct_task_transport_test",
  885. size = "small",
  886. srcs = ["src/ray/core_worker/test/direct_task_transport_test.cc"],
  887. copts = COPTS,
  888. tags = ["team:core"],
  889. deps = [
  890. ":core_worker_lib",
  891. ":ray_mock",
  892. "@com_google_googletest//:gtest_main",
  893. ],
  894. )
  895. cc_test(
  896. name = "direct_task_transport_mock_test",
  897. size = "small",
  898. srcs = ["src/ray/core_worker/test/direct_task_transport_mock_test.cc"],
  899. copts = COPTS,
  900. tags = ["team:core"],
  901. deps = [
  902. ":core_worker_lib",
  903. ":ray_mock",
  904. "@com_google_googletest//:gtest_main",
  905. ],
  906. )
  907. cc_test(
  908. name = "reference_count_test",
  909. size = "small",
  910. srcs = ["src/ray/core_worker/test/reference_count_test.cc"],
  911. copts = COPTS,
  912. tags = ["team:core"],
  913. deps = [
  914. ":core_worker_lib",
  915. "@com_google_googletest//:gtest_main",
  916. ],
  917. )
  918. cc_test(
  919. name = "object_recovery_manager_test",
  920. size = "small",
  921. srcs = ["src/ray/core_worker/test/object_recovery_manager_test.cc"],
  922. copts = COPTS,
  923. tags = ["team:core"],
  924. deps = [
  925. ":core_worker_lib",
  926. "@com_google_googletest//:gtest_main",
  927. ],
  928. )
  929. cc_test(
  930. name = "scheduling_queue_test",
  931. srcs = ["src/ray/core_worker/test/scheduling_queue_test.cc"],
  932. copts = COPTS,
  933. tags = ["team:core"],
  934. deps = [
  935. ":core_worker_lib",
  936. "@com_google_googletest//:gtest_main",
  937. ],
  938. )
  939. cc_test(
  940. name = "concurrency_group_manager_test",
  941. srcs = ["src/ray/core_worker/test/concurrency_group_manager_test.cc"],
  942. copts = COPTS,
  943. tags = ["team:core"],
  944. deps = [
  945. ":core_worker_lib",
  946. "@com_google_googletest//:gtest_main",
  947. ],
  948. )
  949. cc_test(
  950. name = "actor_submit_queue_test",
  951. size = "small",
  952. srcs = ["src/ray/core_worker/test/actor_submit_queue_test.cc"],
  953. copts = COPTS,
  954. tags = ["team:core"],
  955. deps = [
  956. ":core_worker_lib",
  957. "@com_google_googletest//:gtest_main",
  958. ],
  959. )
  960. cc_test(
  961. name = "task_manager_test",
  962. size = "small",
  963. srcs = ["src/ray/core_worker/test/task_manager_test.cc"],
  964. copts = COPTS,
  965. tags = ["team:core"],
  966. deps = [
  967. ":core_worker_lib",
  968. ":ray_mock",
  969. "@com_google_googletest//:gtest_main",
  970. ],
  971. )
  972. cc_test(
  973. name = "task_event_buffer_test",
  974. size = "small",
  975. srcs = ["src/ray/core_worker/test/task_event_buffer_test.cc"],
  976. copts = COPTS,
  977. tags = ["team:core"],
  978. deps = [
  979. ":core_worker_lib",
  980. ":ray_mock",
  981. "@com_google_googletest//:gtest_main",
  982. ],
  983. )
  984. cc_test(
  985. name = "actor_creator_test",
  986. size = "small",
  987. srcs = ["src/ray/core_worker/test/actor_creator_test.cc"],
  988. copts = COPTS,
  989. tags = ["team:core"],
  990. deps = [
  991. ":core_worker_lib",
  992. ":gcs_client_lib",
  993. ":ray_mock",
  994. "//src/ray/common:test_util",
  995. "@com_google_googletest//:gtest_main",
  996. ],
  997. )
  998. cc_test(
  999. name = "actor_manager_test",
  1000. size = "small",
  1001. srcs = ["src/ray/core_worker/test/actor_manager_test.cc"],
  1002. copts = COPTS,
  1003. tags = ["team:core"],
  1004. deps = [
  1005. ":core_worker_lib",
  1006. "@com_google_googletest//:gtest_main",
  1007. ],
  1008. )
  1009. cc_test(
  1010. name = "lease_policy_test",
  1011. size = "small",
  1012. srcs = ["src/ray/core_worker/test/lease_policy_test.cc"],
  1013. copts = COPTS,
  1014. tags = ["team:core"],
  1015. deps = [
  1016. ":core_worker_lib",
  1017. "@com_google_googletest//:gtest_main",
  1018. ],
  1019. )
  1020. cc_test(
  1021. name = "cluster_resource_scheduler_test",
  1022. size = "small",
  1023. srcs = [
  1024. "src/ray/raylet/scheduling/cluster_resource_scheduler_test.cc",
  1025. ],
  1026. copts = COPTS,
  1027. tags = ["team:core"],
  1028. deps = [
  1029. ":ray_mock",
  1030. ":raylet_lib",
  1031. "@com_google_googletest//:gtest_main",
  1032. ],
  1033. )
  1034. cc_test(
  1035. name = "local_resource_manager_test",
  1036. size = "small",
  1037. srcs = [
  1038. "src/ray/raylet/scheduling/local_resource_manager_test.cc",
  1039. ],
  1040. copts = COPTS,
  1041. tags = ["team:core"],
  1042. deps = [
  1043. ":ray_mock",
  1044. ":raylet_lib",
  1045. "@com_google_googletest//:gtest_main",
  1046. ],
  1047. )
  1048. cc_test(
  1049. name = "cluster_resource_scheduler_2_test",
  1050. size = "small",
  1051. srcs = [
  1052. "src/ray/raylet/scheduling/cluster_resource_scheduler_2_test.cc",
  1053. ],
  1054. copts = COPTS,
  1055. tags = ["team:core"],
  1056. deps = [
  1057. ":raylet_lib",
  1058. "@com_google_googletest//:gtest_main",
  1059. ],
  1060. )
  1061. cc_test(
  1062. name = "scheduling_policy_test",
  1063. size = "small",
  1064. srcs = [
  1065. "src/ray/raylet/scheduling/policy/scheduling_policy_test.cc",
  1066. ],
  1067. copts = COPTS,
  1068. tags = ["team:core"],
  1069. deps = [
  1070. ":raylet_lib",
  1071. "@com_google_googletest//:gtest_main",
  1072. ],
  1073. )
  1074. cc_test(
  1075. name = "hybrid_scheduling_policy_test",
  1076. size = "small",
  1077. srcs = [
  1078. "src/ray/raylet/scheduling/policy/hybrid_scheduling_policy_test.cc",
  1079. ],
  1080. copts = COPTS,
  1081. tags = ["team:core"],
  1082. deps = [
  1083. ":scheduler",
  1084. "@com_google_absl//absl/random:mock_distributions",
  1085. "@com_google_googletest//:gtest_main",
  1086. ],
  1087. )
  1088. cc_test(
  1089. name = "cluster_task_manager_test",
  1090. size = "small",
  1091. srcs = [
  1092. "src/ray/raylet/scheduling/cluster_task_manager_test.cc",
  1093. ],
  1094. copts = COPTS,
  1095. tags = ["team:core"],
  1096. deps = [
  1097. ":ray_mock",
  1098. ":raylet_lib",
  1099. "@com_google_googletest//:gtest_main",
  1100. ],
  1101. )
  1102. cc_test(
  1103. name = "cluster_resource_manager_test",
  1104. size = "small",
  1105. srcs = [
  1106. "src/ray/raylet/scheduling/cluster_resource_manager_test.cc",
  1107. ],
  1108. copts = COPTS,
  1109. tags = ["team:core"],
  1110. deps = [
  1111. ":raylet_lib",
  1112. "@com_google_googletest//:gtest_main",
  1113. ],
  1114. )
  1115. cc_test(
  1116. name = "local_object_manager_test",
  1117. size = "small",
  1118. srcs = [
  1119. "src/ray/raylet/test/local_object_manager_test.cc",
  1120. ],
  1121. copts = COPTS,
  1122. tags = ["team:core"],
  1123. deps = [
  1124. ":raylet_lib",
  1125. "@com_google_googletest//:gtest_main",
  1126. ],
  1127. )
  1128. cc_test(
  1129. name = "pull_manager_test",
  1130. size = "small",
  1131. srcs = [
  1132. "src/ray/object_manager/test/pull_manager_test.cc",
  1133. ],
  1134. copts = COPTS,
  1135. tags = ["team:core"],
  1136. deps = [
  1137. ":object_manager",
  1138. "@com_google_googletest//:gtest_main",
  1139. ],
  1140. )
  1141. cc_test(
  1142. name = "object_buffer_pool_test",
  1143. size = "small",
  1144. srcs = [
  1145. "src/ray/object_manager/test/object_buffer_pool_test.cc",
  1146. ],
  1147. copts = COPTS,
  1148. tags = ["team:core"],
  1149. deps = [
  1150. ":object_manager",
  1151. "@com_google_googletest//:gtest_main",
  1152. ],
  1153. )
  1154. cc_test(
  1155. name = "ownership_based_object_directory_test",
  1156. size = "small",
  1157. srcs = [
  1158. "src/ray/object_manager/test/ownership_based_object_directory_test.cc",
  1159. ],
  1160. copts = COPTS,
  1161. tags = ["team:core"],
  1162. deps = [
  1163. ":object_manager",
  1164. ":ray_mock",
  1165. "@com_google_googletest//:gtest_main",
  1166. ],
  1167. )
  1168. cc_test(
  1169. name = "push_manager_test",
  1170. size = "small",
  1171. srcs = [
  1172. "src/ray/object_manager/test/push_manager_test.cc",
  1173. ],
  1174. copts = COPTS,
  1175. tags = ["team:core"],
  1176. deps = [
  1177. ":raylet_lib",
  1178. "@com_google_googletest//:gtest_main",
  1179. ],
  1180. )
  1181. cc_test(
  1182. name = "spilled_object_test",
  1183. size = "small",
  1184. srcs = [
  1185. "src/ray/object_manager/test/spilled_object_test.cc",
  1186. ],
  1187. copts = COPTS,
  1188. tags = ["team:core"],
  1189. deps = [
  1190. ":raylet_lib",
  1191. "@boost//:endian",
  1192. "@com_google_absl//absl/strings:str_format",
  1193. "@com_google_googletest//:gtest_main",
  1194. ],
  1195. )
  1196. cc_test(
  1197. name = "fallback_allocator_test",
  1198. srcs = [
  1199. "src/ray/object_manager/plasma/test/fallback_allocator_test.cc",
  1200. ],
  1201. copts = COPTS,
  1202. tags = ["team:core"],
  1203. deps = [
  1204. ":plasma_store_server_lib",
  1205. "@com_google_absl//absl/strings:str_format",
  1206. "@com_google_googletest//:gtest_main",
  1207. ],
  1208. )
  1209. cc_test(
  1210. name = "object_store_test",
  1211. srcs = [
  1212. "src/ray/object_manager/plasma/test/object_store_test.cc",
  1213. ],
  1214. copts = COPTS,
  1215. tags = ["team:core"],
  1216. deps = [
  1217. ":plasma_store_server_lib",
  1218. "@com_google_absl//absl/random",
  1219. "@com_google_absl//absl/strings:str_format",
  1220. "@com_google_googletest//:gtest_main",
  1221. ],
  1222. )
  1223. cc_test(
  1224. name = "object_lifecycle_manager_test",
  1225. srcs = [
  1226. "src/ray/object_manager/plasma/test/object_lifecycle_manager_test.cc",
  1227. "src/ray/object_manager/plasma/test/stats_collector_test.cc",
  1228. ],
  1229. copts = COPTS,
  1230. tags = ["team:core"],
  1231. deps = [
  1232. ":plasma_store_server_lib",
  1233. "@com_google_absl//absl/random",
  1234. "@com_google_absl//absl/strings:str_format",
  1235. "@com_google_googletest//:gtest_main",
  1236. ],
  1237. )
  1238. cc_test(
  1239. name = "eviction_policy_test",
  1240. srcs = [
  1241. "src/ray/object_manager/plasma/test/eviction_policy_test.cc",
  1242. ],
  1243. copts = COPTS,
  1244. tags = ["team:core"],
  1245. deps = [
  1246. ":plasma_store_server_lib",
  1247. "@com_google_googletest//:gtest_main",
  1248. ],
  1249. )
  1250. cc_test(
  1251. name = "create_request_queue_test",
  1252. size = "small",
  1253. srcs = [
  1254. "src/ray/object_manager/test/create_request_queue_test.cc",
  1255. ],
  1256. copts = COPTS,
  1257. tags = ["team:core"],
  1258. deps = [
  1259. ":plasma_store_server_lib",
  1260. "@com_google_googletest//:gtest",
  1261. "@com_google_googletest//:gtest_main",
  1262. ],
  1263. )
  1264. cc_test(
  1265. name = "get_request_queue_test",
  1266. size = "small",
  1267. srcs = [
  1268. "src/ray/object_manager/test/get_request_queue_test.cc",
  1269. ],
  1270. copts = COPTS,
  1271. tags = ["team:core"],
  1272. deps = [
  1273. ":plasma_store_server_lib",
  1274. "@com_google_googletest//:gtest",
  1275. "@com_google_googletest//:gtest_main",
  1276. ],
  1277. )
  1278. cc_test(
  1279. name = "worker_pool_test",
  1280. size = "small",
  1281. srcs = ["src/ray/raylet/worker_pool_test.cc"],
  1282. copts = COPTS,
  1283. tags = ["team:core"],
  1284. deps = [
  1285. ":raylet_lib",
  1286. "@com_google_googletest//:gtest_main",
  1287. ],
  1288. )
  1289. cc_test(
  1290. name = "gcs_placement_group_manager_mock_test",
  1291. size = "small",
  1292. srcs = [
  1293. "src/ray/gcs/gcs_server/test/gcs_placement_group_manager_mock_test.cc",
  1294. ],
  1295. copts = COPTS,
  1296. tags = ["team:core"],
  1297. deps = [
  1298. ":gcs_server_lib",
  1299. ":gcs_test_util_lib",
  1300. ":ray_mock",
  1301. "@com_google_googletest//:gtest_main",
  1302. ],
  1303. )
  1304. cc_test(
  1305. name = "placement_group_resource_manager_test",
  1306. size = "small",
  1307. srcs = ["src/ray/raylet/placement_group_resource_manager_test.cc"],
  1308. copts = COPTS,
  1309. tags = ["team:core"],
  1310. deps = [
  1311. "gcs_test_util_lib",
  1312. "ray_common",
  1313. "raylet_lib",
  1314. ":ray_mock",
  1315. "@com_google_googletest//:gtest_main",
  1316. ],
  1317. )
  1318. cc_test(
  1319. name = "runtime_env_agent_client_test",
  1320. size = "small",
  1321. srcs = ["src/ray/raylet/runtime_env_agent_client_test.cc"],
  1322. copts = COPTS,
  1323. tags = ["team:core"],
  1324. deps = [
  1325. "gcs_test_util_lib",
  1326. "ray_common",
  1327. "raylet_lib",
  1328. ":ray_mock",
  1329. "@com_google_googletest//:gtest_main",
  1330. ],
  1331. )
  1332. cc_test(
  1333. name = "dependency_manager_test",
  1334. size = "small",
  1335. srcs = ["src/ray/raylet/dependency_manager_test.cc"],
  1336. copts = COPTS,
  1337. tags = ["team:core"],
  1338. deps = [
  1339. ":raylet_lib",
  1340. "@com_google_googletest//:gtest_main",
  1341. ],
  1342. )
  1343. cc_test(
  1344. name = "wait_manager_test",
  1345. size = "small",
  1346. srcs = ["src/ray/raylet/wait_manager_test.cc"],
  1347. copts = COPTS,
  1348. tags = ["team:core"],
  1349. deps = [
  1350. ":raylet_lib",
  1351. "@com_google_googletest//:gtest_main",
  1352. ],
  1353. )
  1354. cc_test(
  1355. name = "worker_killing_policy_test",
  1356. size = "small",
  1357. srcs = [
  1358. "src/ray/raylet/worker_killing_policy_test.cc",
  1359. ],
  1360. copts = COPTS,
  1361. tags = ["team:core"],
  1362. deps = [
  1363. ":ray_common",
  1364. ":raylet_lib",
  1365. "@com_google_googletest//:gtest_main",
  1366. ],
  1367. )
  1368. cc_test(
  1369. name = "worker_killing_policy_group_by_owner_test",
  1370. size = "small",
  1371. srcs = [
  1372. "src/ray/raylet/worker_killing_policy_group_by_owner_test.cc",
  1373. ],
  1374. copts = COPTS,
  1375. tags = ["team:core"],
  1376. deps = [
  1377. ":ray_common",
  1378. ":raylet_lib",
  1379. "@com_google_googletest//:gtest_main",
  1380. ],
  1381. )
  1382. cc_test(
  1383. name = "worker_killing_policy_retriable_fifo_test",
  1384. size = "small",
  1385. srcs = [
  1386. "src/ray/raylet/worker_killing_policy_retriable_fifo_test.cc",
  1387. ],
  1388. copts = COPTS,
  1389. tags = ["team:core"],
  1390. deps = [
  1391. ":ray_common",
  1392. ":raylet_lib",
  1393. "@com_google_googletest//:gtest_main",
  1394. ],
  1395. )
  1396. cc_test(
  1397. name = "pubsub_integration_test",
  1398. size = "small",
  1399. srcs = ["src/ray/pubsub/test/integration_test.cc"],
  1400. copts = COPTS,
  1401. tags = ["team:core"],
  1402. deps = [
  1403. ":pubsub_cc_grpc",
  1404. ":pubsub_lib",
  1405. "//src/ray/protobuf:pubsub_cc_proto",
  1406. "@com_google_absl//absl/synchronization",
  1407. "@com_google_absl//absl/time",
  1408. "@com_google_googletest//:gtest_main",
  1409. ],
  1410. )
  1411. cc_test(
  1412. name = "publisher_test",
  1413. size = "small",
  1414. srcs = ["src/ray/pubsub/test/publisher_test.cc"],
  1415. copts = COPTS,
  1416. tags = ["team:core"],
  1417. deps = [
  1418. ":pubsub_lib",
  1419. "@com_google_googletest//:gtest_main",
  1420. ],
  1421. )
  1422. cc_test(
  1423. name = "subscriber_test",
  1424. size = "small",
  1425. srcs = [
  1426. "src/ray/pubsub/test/subscriber_test.cc",
  1427. ],
  1428. copts = COPTS,
  1429. tags = ["team:core"],
  1430. deps = [
  1431. ":pubsub_lib",
  1432. "@com_google_googletest//:gtest_main",
  1433. ],
  1434. )
  1435. cc_test(
  1436. name = "stats_test",
  1437. size = "small",
  1438. srcs = ["src/ray/stats/stats_test.cc"],
  1439. copts = COPTS,
  1440. tags = [
  1441. "stats",
  1442. "team:core",
  1443. ],
  1444. deps = [
  1445. ":stats_lib",
  1446. "@com_google_googletest//:gtest_main",
  1447. ],
  1448. )
  1449. cc_test(
  1450. name = "metric_exporter_client_test",
  1451. size = "small",
  1452. srcs = ["src/ray/stats/metric_exporter_client_test.cc"],
  1453. copts = COPTS,
  1454. tags = [
  1455. "stats",
  1456. "team:core",
  1457. ],
  1458. deps = [
  1459. ":stats_lib",
  1460. "@com_google_googletest//:gtest_main",
  1461. ],
  1462. )
  1463. cc_library(
  1464. name = "gcs_test_util_lib",
  1465. hdrs = [
  1466. "src/ray/gcs/test/gcs_test_util.h",
  1467. ],
  1468. copts = COPTS,
  1469. strip_include_prefix = "src",
  1470. deps = [
  1471. ":gcs",
  1472. ":gcs_service_rpc",
  1473. ],
  1474. )
  1475. cc_test(
  1476. name = "grpc_server_client_test",
  1477. size = "small",
  1478. srcs = [
  1479. "src/ray/rpc/test/grpc_server_client_test.cc",
  1480. ],
  1481. copts = COPTS,
  1482. tags = ["team:core"],
  1483. deps = [
  1484. ":grpc_common_lib",
  1485. ":test_service_cc_grpc",
  1486. ],
  1487. )
  1488. cc_test(
  1489. name = "gcs_server_rpc_test",
  1490. size = "small",
  1491. srcs = [
  1492. "src/ray/gcs/gcs_server/test/gcs_server_rpc_test.cc",
  1493. ],
  1494. args = [
  1495. "$(location redis-server)",
  1496. "$(location redis-cli)",
  1497. ],
  1498. copts = COPTS,
  1499. data = [
  1500. "//:redis-cli",
  1501. "//:redis-server",
  1502. ],
  1503. tags = ["team:core"],
  1504. deps = [
  1505. ":gcs_server_lib",
  1506. ":gcs_test_util_lib",
  1507. "@com_google_googletest//:gtest_main",
  1508. ],
  1509. )
  1510. cc_test(
  1511. name = "gcs_kv_manager_test",
  1512. size = "small",
  1513. srcs = [
  1514. "src/ray/gcs/gcs_server/test/gcs_kv_manager_test.cc",
  1515. ],
  1516. args = [
  1517. "$(location redis-server)",
  1518. "$(location redis-cli)",
  1519. ],
  1520. copts = COPTS,
  1521. data = [
  1522. "//:redis-cli",
  1523. "//:redis-server",
  1524. ],
  1525. tags = ["team:core"],
  1526. deps = [
  1527. ":gcs_server_lib",
  1528. ":gcs_test_util_lib",
  1529. "@com_google_googletest//:gtest_main",
  1530. ],
  1531. )
  1532. cc_library(
  1533. name = "gcs_server_test_util",
  1534. hdrs = [
  1535. "src/ray/gcs/gcs_server/test/gcs_server_test_util.h",
  1536. ],
  1537. copts = COPTS,
  1538. strip_include_prefix = "src",
  1539. deps = [
  1540. ":gcs_client_lib",
  1541. ],
  1542. )
  1543. cc_test(
  1544. name = "gcs_health_check_manager_test",
  1545. size = "medium",
  1546. srcs = [
  1547. "src/ray/gcs/gcs_server/test/gcs_health_check_manager_test.cc",
  1548. ],
  1549. copts = COPTS,
  1550. tags = ["team:core"],
  1551. deps = [
  1552. ":gcs_server_lib",
  1553. "@com_google_googletest//:gtest_main",
  1554. ],
  1555. )
  1556. cc_test(
  1557. name = "gcs_node_manager_test",
  1558. size = "small",
  1559. srcs = [
  1560. "src/ray/gcs/gcs_server/test/gcs_node_manager_test.cc",
  1561. ],
  1562. copts = COPTS,
  1563. tags = ["team:core"],
  1564. deps = [
  1565. ":gcs_server_lib",
  1566. ":gcs_server_test_util",
  1567. ":gcs_test_util_lib",
  1568. ":ray_mock",
  1569. "@com_google_googletest//:gtest_main",
  1570. ],
  1571. )
  1572. cc_test(
  1573. name = "gcs_job_manager_test",
  1574. size = "small",
  1575. srcs = [
  1576. "src/ray/gcs/gcs_server/test/gcs_job_manager_test.cc",
  1577. ],
  1578. copts = COPTS,
  1579. tags = ["team:core"],
  1580. deps = [
  1581. ":gcs_server_lib",
  1582. ":gcs_server_test_util",
  1583. ":gcs_test_util_lib",
  1584. ":ray_mock",
  1585. "@com_google_googletest//:gtest_main",
  1586. ],
  1587. )
  1588. cc_test(
  1589. name = "gcs_task_manager_test",
  1590. size = "small",
  1591. srcs = [
  1592. "src/ray/gcs/gcs_server/test/gcs_task_manager_test.cc",
  1593. ],
  1594. copts = COPTS,
  1595. tags = ["team:core"],
  1596. deps = [
  1597. ":gcs_server_lib",
  1598. ":gcs_server_test_util",
  1599. ":gcs_test_util_lib",
  1600. ":ray_mock",
  1601. "@com_google_googletest//:gtest_main",
  1602. ],
  1603. )
  1604. cc_test(
  1605. name = "gcs_placement_group_manager_test",
  1606. size = "small",
  1607. srcs = [
  1608. "src/ray/gcs/gcs_server/test/gcs_placement_group_manager_test.cc",
  1609. ],
  1610. copts = COPTS,
  1611. tags = ["team:core"],
  1612. deps = [
  1613. ":gcs_server_lib",
  1614. ":gcs_server_test_util",
  1615. ":gcs_test_util_lib",
  1616. ":ray_mock",
  1617. "@com_google_googletest//:gtest_main",
  1618. ],
  1619. )
  1620. cc_test(
  1621. name = "gcs_placement_group_scheduler_test",
  1622. size = "small",
  1623. srcs = [
  1624. "src/ray/gcs/gcs_server/test/gcs_placement_group_scheduler_test.cc",
  1625. ],
  1626. copts = COPTS,
  1627. tags = ["team:core"],
  1628. deps = [
  1629. ":gcs_server_lib",
  1630. ":gcs_server_test_util",
  1631. ":gcs_test_util_lib",
  1632. ":ray_mock",
  1633. "@com_google_googletest//:gtest_main",
  1634. ],
  1635. )
  1636. cc_test(
  1637. name = "gcs_actor_scheduler_test",
  1638. size = "small",
  1639. srcs = [
  1640. "src/ray/gcs/gcs_server/test/gcs_actor_scheduler_test.cc",
  1641. ],
  1642. copts = COPTS,
  1643. tags = ["team:core"],
  1644. deps = [
  1645. ":gcs_client_lib",
  1646. ":gcs_server_lib",
  1647. ":gcs_server_test_util",
  1648. ":gcs_test_util_lib",
  1649. ":ray_mock",
  1650. "@com_google_googletest//:gtest_main",
  1651. ],
  1652. )
  1653. cc_test(
  1654. name = "gcs_actor_scheduler_mock_test",
  1655. size = "small",
  1656. srcs = [
  1657. "src/ray/gcs/gcs_server/test/gcs_actor_scheduler_mock_test.cc",
  1658. ],
  1659. copts = COPTS,
  1660. tags = ["team:core"],
  1661. deps = [
  1662. ":gcs_server_lib",
  1663. ":ray_mock",
  1664. "@com_google_googletest//:gtest_main",
  1665. ],
  1666. )
  1667. cc_test(
  1668. name = "gcs_actor_manager_test",
  1669. size = "small",
  1670. srcs = [
  1671. "src/ray/gcs/gcs_server/test/gcs_actor_manager_test.cc",
  1672. ],
  1673. copts = COPTS,
  1674. tags = ["team:core"],
  1675. deps = [
  1676. ":gcs_server_lib",
  1677. ":gcs_server_test_util",
  1678. ":gcs_test_util_lib",
  1679. ":ray_mock",
  1680. "@com_google_googletest//:gtest_main",
  1681. ],
  1682. )
  1683. cc_test(
  1684. name = "gcs_worker_manager_test",
  1685. size = "small",
  1686. srcs = [
  1687. "src/ray/gcs/gcs_server/test/gcs_worker_manager_test.cc",
  1688. ],
  1689. copts = COPTS,
  1690. tags = ["team:core"],
  1691. deps = [
  1692. ":gcs_server_lib",
  1693. ":gcs_server_test_util",
  1694. ":gcs_test_util_lib",
  1695. ":ray_mock",
  1696. "@com_google_googletest//:gtest_main",
  1697. ],
  1698. )
  1699. cc_test(
  1700. name = "gcs_monitor_server_test",
  1701. size = "small",
  1702. srcs = [
  1703. "src/ray/gcs/gcs_server/test/gcs_monitor_server_test.cc",
  1704. ],
  1705. copts = COPTS,
  1706. tags = ["team:serverless"],
  1707. deps = [
  1708. ":gcs_server_lib",
  1709. ":gcs_server_test_util",
  1710. ":gcs_test_util_lib",
  1711. ":ray_mock",
  1712. "@com_google_googletest//:gtest_main",
  1713. ],
  1714. )
  1715. cc_library(
  1716. name = "gcs_table_storage_lib",
  1717. srcs = glob(
  1718. [
  1719. "src/ray/gcs/gcs_server/gcs_table_storage.cc",
  1720. ],
  1721. ),
  1722. hdrs = glob(
  1723. [
  1724. "src/ray/gcs/gcs_server/gcs_table_storage.h",
  1725. ],
  1726. ),
  1727. copts = COPTS,
  1728. strip_include_prefix = "src",
  1729. deps = [
  1730. ":gcs",
  1731. ":gcs_in_memory_store_client",
  1732. ":observable_store_client",
  1733. ":pubsub_lib",
  1734. ":ray_common",
  1735. ":redis_store_client",
  1736. ],
  1737. )
  1738. cc_library(
  1739. name = "gcs_table_storage_test_lib",
  1740. hdrs = [
  1741. "src/ray/gcs/gcs_server/test/gcs_table_storage_test_base.h",
  1742. ],
  1743. copts = COPTS,
  1744. strip_include_prefix = "src",
  1745. deps = [
  1746. "redis_store_client",
  1747. ],
  1748. )
  1749. cc_test(
  1750. name = "redis_gcs_table_storage_test",
  1751. size = "small",
  1752. srcs = [
  1753. "src/ray/gcs/gcs_server/test/redis_gcs_table_storage_test.cc",
  1754. ],
  1755. args = [
  1756. "$(location redis-server)",
  1757. "$(location redis-cli)",
  1758. ],
  1759. copts = COPTS,
  1760. data = [
  1761. "//:redis-cli",
  1762. "//:redis-server",
  1763. ],
  1764. tags = ["team:core"],
  1765. deps = [
  1766. ":gcs_table_storage_lib",
  1767. ":gcs_table_storage_test_lib",
  1768. ":gcs_test_util_lib",
  1769. ":store_client_test_lib",
  1770. "@com_google_googletest//:gtest_main",
  1771. ],
  1772. )
  1773. cc_test(
  1774. name = "in_memory_gcs_table_storage_test",
  1775. size = "small",
  1776. srcs = [
  1777. "src/ray/gcs/gcs_server/test/in_memory_gcs_table_storage_test.cc",
  1778. ],
  1779. copts = COPTS,
  1780. tags = ["team:core"],
  1781. deps = [
  1782. ":gcs_table_storage_lib",
  1783. ":gcs_table_storage_test_lib",
  1784. ":gcs_test_util_lib",
  1785. ":store_client_test_lib",
  1786. "@com_google_googletest//:gtest_main",
  1787. ],
  1788. )
  1789. cc_test(
  1790. name = "gcs_autoscaler_state_manager_test",
  1791. size = "small",
  1792. srcs = [
  1793. "src/ray/gcs/gcs_server/test/gcs_autoscaler_state_manager_test.cc",
  1794. ],
  1795. copts = COPTS,
  1796. tags = ["team:core"],
  1797. deps = [
  1798. ":gcs_server_lib",
  1799. ":gcs_server_test_util",
  1800. ":gcs_test_util_lib",
  1801. ":ray_mock",
  1802. "@com_google_googletest//:gtest_main",
  1803. ],
  1804. )
  1805. cc_test(
  1806. name = "gcs_resource_manager_test",
  1807. size = "small",
  1808. srcs = [
  1809. "src/ray/gcs/gcs_server/test/gcs_resource_manager_test.cc",
  1810. ],
  1811. copts = COPTS,
  1812. tags = ["team:core"],
  1813. deps = [
  1814. ":gcs_server_lib",
  1815. ":gcs_test_util_lib",
  1816. "@com_google_googletest//:gtest_main",
  1817. ],
  1818. )
  1819. cc_test(
  1820. name = "gcs_resource_report_poller_test",
  1821. size = "small",
  1822. srcs = [
  1823. "src/ray/gcs/gcs_server/test/gcs_resource_report_poller_test.cc",
  1824. ],
  1825. copts = COPTS,
  1826. tags = ["team:core"],
  1827. deps = [
  1828. ":gcs_server_lib",
  1829. ":gcs_test_util_lib",
  1830. "@com_google_googletest//:gtest_main",
  1831. ],
  1832. )
  1833. cc_test(
  1834. name = "grpc_based_resource_broadcaster_test",
  1835. size = "small",
  1836. srcs = [
  1837. "src/ray/gcs/gcs_server/test/grpc_based_resource_broadcaster_test.cc",
  1838. ],
  1839. copts = COPTS,
  1840. tags = ["team:core"],
  1841. deps = [
  1842. ":gcs_server_lib",
  1843. ":gcs_test_util_lib",
  1844. "@com_google_googletest//:gtest_main",
  1845. ],
  1846. )
  1847. cc_library(
  1848. name = "gcs_client_lib",
  1849. srcs = [
  1850. "src/ray/gcs/gcs_client/accessor.cc",
  1851. "src/ray/gcs/gcs_client/gcs_client.cc",
  1852. "src/ray/gcs/gcs_client/usage_stats_client.cc",
  1853. ],
  1854. hdrs = [
  1855. "src/ray/gcs/gcs_client/accessor.h",
  1856. "src/ray/gcs/gcs_client/gcs_client.h",
  1857. "src/ray/gcs/gcs_client/usage_stats_client.h",
  1858. ],
  1859. copts = COPTS,
  1860. strip_include_prefix = "src",
  1861. deps = [
  1862. ":gcs",
  1863. ":gcs_pub_sub_lib",
  1864. ":gcs_service_rpc",
  1865. ":pubsub_lib",
  1866. ":ray_common",
  1867. ":redis_store_client",
  1868. "//src/ray/protobuf:usage_cc_proto",
  1869. ],
  1870. )
  1871. cc_library(
  1872. name = "global_state_accessor_lib",
  1873. srcs = glob(
  1874. [
  1875. "src/ray/gcs/gcs_client/global_state_accessor.cc",
  1876. ],
  1877. ),
  1878. hdrs = glob(
  1879. [
  1880. "src/ray/gcs/gcs_client/global_state_accessor.h",
  1881. ],
  1882. ),
  1883. copts = COPTS,
  1884. strip_include_prefix = "src",
  1885. visibility = ["//visibility:public"],
  1886. deps = [
  1887. ":gcs_client_lib",
  1888. ],
  1889. )
  1890. cc_test(
  1891. name = "accessor_test",
  1892. size = "small",
  1893. srcs = [
  1894. "src/ray/gcs/gcs_client/test/accessor_test.cc",
  1895. ],
  1896. copts = COPTS,
  1897. tags = ["team:core"],
  1898. deps = [
  1899. ":gcs_client_lib",
  1900. ":gcs_test_util_lib",
  1901. "@com_google_googletest//:gtest_main",
  1902. ],
  1903. )
  1904. cc_test(
  1905. name = "global_state_accessor_test",
  1906. size = "small",
  1907. srcs = [
  1908. "src/ray/gcs/gcs_client/test/global_state_accessor_test.cc",
  1909. ],
  1910. args = [
  1911. "$(location redis-server)",
  1912. "$(location redis-cli)",
  1913. ],
  1914. copts = COPTS,
  1915. data = [
  1916. "//:redis-cli",
  1917. "//:redis-server",
  1918. ],
  1919. tags = ["team:core"],
  1920. deps = [
  1921. ":gcs_client_lib",
  1922. ":gcs_server_lib",
  1923. ":gcs_test_util_lib",
  1924. ":global_state_accessor_lib",
  1925. "@com_google_googletest//:gtest_main",
  1926. ],
  1927. )
  1928. cc_test(
  1929. name = "gcs_client_test",
  1930. size = "medium",
  1931. srcs = [
  1932. "src/ray/gcs/gcs_client/test/gcs_client_test.cc",
  1933. ],
  1934. args = [
  1935. "$(location redis-server)",
  1936. "$(location redis-cli)",
  1937. ],
  1938. copts = COPTS,
  1939. data = [
  1940. "//:redis-cli",
  1941. "//:redis-server",
  1942. ],
  1943. tags = ["team:core"],
  1944. deps = [
  1945. ":gcs_client_lib",
  1946. ":gcs_server_lib",
  1947. ":gcs_test_util_lib",
  1948. "@com_google_googletest//:gtest_main",
  1949. ],
  1950. )
  1951. cc_test(
  1952. name = "gcs_client_reconnection_test",
  1953. srcs = [
  1954. "src/ray/gcs/gcs_client/test/gcs_client_reconnection_test.cc",
  1955. ],
  1956. args = [
  1957. "$(location redis-server)",
  1958. "$(location redis-cli)",
  1959. ],
  1960. copts = COPTS,
  1961. data = [
  1962. "//:redis-cli",
  1963. "//:redis-server",
  1964. ],
  1965. tags = ["team:core"],
  1966. deps = [
  1967. ":gcs_client_lib",
  1968. ":gcs_server_lib",
  1969. ":gcs_test_util_lib",
  1970. "@com_google_googletest//:gtest_main",
  1971. ],
  1972. )
  1973. cc_test(
  1974. name = "usage_stats_client_test",
  1975. srcs = [
  1976. "src/ray/gcs/gcs_client/test/usage_stats_client_test.cc",
  1977. ],
  1978. copts = COPTS,
  1979. tags = ["team:core"],
  1980. deps = [
  1981. ":gcs_client_lib",
  1982. ":gcs_server_lib",
  1983. ":gcs_test_util_lib",
  1984. "@com_google_googletest//:gtest_main",
  1985. ],
  1986. )
  1987. cc_library(
  1988. name = "object_manager",
  1989. srcs = glob([
  1990. "src/ray/object_manager/*.cc",
  1991. "src/ray/object_manager/notification/*.cc",
  1992. ]),
  1993. hdrs = glob([
  1994. "src/ray/object_manager/*.h",
  1995. "src/ray/object_manager/notification/*.h",
  1996. ]),
  1997. copts = COPTS,
  1998. strip_include_prefix = "src",
  1999. deps = [
  2000. ":core_worker_lib",
  2001. ":gcs",
  2002. ":object_manager_rpc",
  2003. ":plasma_store_server_lib",
  2004. ":ray_common",
  2005. "//src/ray/util",
  2006. "@boost//:asio",
  2007. ],
  2008. )
  2009. cc_library(
  2010. name = "platform_shims",
  2011. srcs = [] + select({
  2012. "@bazel_tools//src/conditions:windows": glob([
  2013. "src/shims/windows/**/*.c",
  2014. "src/shims/windows/**/*.cc",
  2015. "src/shims/windows/**/*.h",
  2016. ]),
  2017. "//conditions:default": [],
  2018. }),
  2019. hdrs = [] + select({
  2020. "@bazel_tools//src/conditions:windows": glob([
  2021. "src/shims/windows/**/*.h",
  2022. ]),
  2023. "//conditions:default": [],
  2024. }),
  2025. copts = COPTS,
  2026. strip_include_prefix = select({
  2027. "@bazel_tools//src/conditions:windows": "src/shims/windows",
  2028. "//conditions:default": "",
  2029. }),
  2030. visibility = ["//visibility:public"],
  2031. )
  2032. filegroup(
  2033. name = "extra_actions_base_proto",
  2034. srcs = [
  2035. "thirdparty/protobuf/extra_actions_base.proto",
  2036. ],
  2037. )
  2038. proto_library(
  2039. name = "extra_actions_base_proto_lib",
  2040. srcs = ["thirdparty/protobuf/extra_actions_base.proto"],
  2041. )
  2042. cc_proto_library(
  2043. name = "extra_actions_cc_proto_lib",
  2044. deps = [":extra_actions_base_proto_lib"],
  2045. )
  2046. filegroup(
  2047. name = "iwyu_sh",
  2048. srcs = ["ci/run/iwyu.sh"],
  2049. )
  2050. action_listener(
  2051. name = "iwyu_cpp",
  2052. extra_actions = [":iwyu_action"],
  2053. mnemonics = ["CppCompile"],
  2054. )
  2055. extra_action(
  2056. name = "iwyu_action",
  2057. cmd = "$(location :iwyu_sh) postbuild $(location @com_google_protobuf//:protoc) $(location :extra_actions_base_proto) --extra_action_file=$(EXTRA_ACTION_FILE) > $(output $(ACTION_ID).iwyu.txt)",
  2058. out_templates = [
  2059. "$(ACTION_ID).iwyu.txt",
  2060. ],
  2061. tools = [
  2062. ":extra_actions_base_proto",
  2063. ":iwyu_sh",
  2064. "@com_google_protobuf//:protoc",
  2065. ],
  2066. )
  2067. cc_library(
  2068. name = "sha256",
  2069. srcs = [
  2070. "src/ray/thirdparty/sha256.c",
  2071. ],
  2072. hdrs = [
  2073. "src/ray/thirdparty/sha256.h",
  2074. ],
  2075. copts = COPTS,
  2076. strip_include_prefix = "src",
  2077. )
  2078. cc_library(
  2079. name = "aligned_alloc",
  2080. srcs = [
  2081. "src/ray/thirdparty/aligned_alloc.c",
  2082. ],
  2083. hdrs = [
  2084. "src/ray/thirdparty/aligned_alloc.h",
  2085. ],
  2086. copts = COPTS,
  2087. strip_include_prefix = "src",
  2088. )
  2089. alias(
  2090. name = "hiredis",
  2091. actual = "@com_github_redis_hiredis//:hiredis",
  2092. )
  2093. cc_library(
  2094. name = "redis_client",
  2095. srcs = [
  2096. "src/ray/gcs/asio.cc",
  2097. "src/ray/gcs/redis_async_context.cc",
  2098. "src/ray/gcs/redis_client.cc",
  2099. "src/ray/gcs/redis_context.cc",
  2100. ],
  2101. hdrs = [
  2102. "src/ray/gcs/asio.h",
  2103. "src/ray/gcs/redis_async_context.h",
  2104. "src/ray/gcs/redis_client.h",
  2105. "src/ray/gcs/redis_context.h",
  2106. ],
  2107. copts = COPTS,
  2108. strip_include_prefix = "src",
  2109. deps = [
  2110. ":hiredis",
  2111. ":ray_common",
  2112. ":stats_lib",
  2113. "//src/ray/util",
  2114. "@boost//:asio",
  2115. ],
  2116. )
  2117. cc_library(
  2118. name = "redis_store_client",
  2119. srcs = [
  2120. "src/ray/gcs/store_client/redis_store_client.cc",
  2121. ],
  2122. hdrs = [
  2123. "src/ray/gcs/callback.h",
  2124. "src/ray/gcs/store_client/redis_store_client.h",
  2125. "src/ray/gcs/store_client/store_client.h",
  2126. ],
  2127. copts = COPTS,
  2128. strip_include_prefix = "src",
  2129. deps = [
  2130. "redis_client",
  2131. "@com_google_absl//absl/strings:str_format",
  2132. "@com_google_absl//absl/synchronization",
  2133. ],
  2134. )
  2135. cc_library(
  2136. name = "gcs_in_memory_store_client",
  2137. srcs = [
  2138. "src/ray/gcs/store_client/in_memory_store_client.cc",
  2139. ],
  2140. hdrs = [
  2141. "src/ray/gcs/callback.h",
  2142. "src/ray/gcs/store_client/in_memory_store_client.h",
  2143. "src/ray/gcs/store_client/store_client.h",
  2144. ],
  2145. copts = COPTS,
  2146. strip_include_prefix = "src",
  2147. deps = [
  2148. ":ray_common",
  2149. "//src/ray/util",
  2150. ],
  2151. )
  2152. cc_library(
  2153. name = "observable_store_client",
  2154. srcs = [
  2155. "src/ray/gcs/store_client/observable_store_client.cc",
  2156. ],
  2157. hdrs = [
  2158. "src/ray/gcs/callback.h",
  2159. "src/ray/gcs/store_client/observable_store_client.h",
  2160. "src/ray/gcs/store_client/store_client.h",
  2161. ],
  2162. copts = COPTS,
  2163. strip_include_prefix = "src",
  2164. deps = [
  2165. ":ray_common",
  2166. "//src/ray/util",
  2167. ],
  2168. )
  2169. cc_library(
  2170. name = "store_client_test_lib",
  2171. hdrs = [
  2172. "src/ray/gcs/store_client/test/store_client_test_base.h",
  2173. ],
  2174. copts = COPTS,
  2175. strip_include_prefix = "src",
  2176. deps = [
  2177. "redis_store_client",
  2178. ],
  2179. )
  2180. cc_test(
  2181. name = "redis_store_client_test",
  2182. size = "small",
  2183. srcs = ["src/ray/gcs/store_client/test/redis_store_client_test.cc"],
  2184. args = [
  2185. "$(location redis-server)",
  2186. "$(location redis-cli)",
  2187. ],
  2188. copts = COPTS,
  2189. data = [
  2190. "//:redis-cli",
  2191. "//:redis-server",
  2192. ],
  2193. tags = ["team:core"],
  2194. deps = [
  2195. ":redis_store_client",
  2196. ":store_client_test_lib",
  2197. "@com_google_googletest//:gtest_main",
  2198. ],
  2199. )
  2200. cc_test(
  2201. name = "chaos_redis_store_client_test",
  2202. size = "small",
  2203. srcs = ["src/ray/gcs/store_client/test/redis_store_client_test.cc"],
  2204. args = [
  2205. "$(location redis-server)",
  2206. "$(location redis-cli)",
  2207. ],
  2208. copts = COPTS,
  2209. data = [
  2210. "//:redis-cli",
  2211. "//:redis-server",
  2212. ],
  2213. env = {"REDIS_CHAOS": "1"},
  2214. tags = ["team:core"],
  2215. target_compatible_with = [
  2216. "@platforms//os:linux",
  2217. ],
  2218. deps = [
  2219. ":redis_store_client",
  2220. ":store_client_test_lib",
  2221. "@com_google_googletest//:gtest_main",
  2222. ],
  2223. )
  2224. cc_test(
  2225. name = "in_memory_store_client_test",
  2226. size = "small",
  2227. srcs = ["src/ray/gcs/store_client/test/in_memory_store_client_test.cc"],
  2228. copts = COPTS,
  2229. tags = ["team:core"],
  2230. deps = [
  2231. ":gcs_in_memory_store_client",
  2232. ":store_client_test_lib",
  2233. "@com_google_googletest//:gtest_main",
  2234. ],
  2235. )
  2236. cc_test(
  2237. name = "observable_store_client_test",
  2238. size = "small",
  2239. srcs = ["src/ray/gcs/store_client/test/in_memory_store_client_test.cc"],
  2240. copts = COPTS,
  2241. tags = ["team:core"],
  2242. deps = [
  2243. ":gcs_in_memory_store_client",
  2244. ":observable_store_client",
  2245. ":store_client_test_lib",
  2246. "@com_google_googletest//:gtest_main",
  2247. ],
  2248. )
  2249. cc_library(
  2250. name = "gcs",
  2251. srcs = glob(
  2252. [
  2253. "src/ray/gcs/*.cc",
  2254. ],
  2255. exclude = [
  2256. "src/ray/gcs/*_test.cc",
  2257. ],
  2258. ),
  2259. hdrs = glob([
  2260. "src/ray/gcs/*.h",
  2261. ]),
  2262. copts = COPTS,
  2263. strip_include_prefix = "src",
  2264. deps = [
  2265. ":hiredis",
  2266. ":node_manager_fbs",
  2267. ":node_manager_rpc",
  2268. ":ray_common",
  2269. ":stats_lib",
  2270. "//src/ray/protobuf:agent_manager_cc_proto",
  2271. "//src/ray/protobuf:gcs_cc_proto",
  2272. "//src/ray/protobuf:gcs_service_cc_proto",
  2273. "//src/ray/util",
  2274. "@boost//:asio",
  2275. ],
  2276. )
  2277. cc_test(
  2278. name = "callback_reply_test",
  2279. size = "small",
  2280. srcs = ["src/ray/gcs/test/callback_reply_test.cc"],
  2281. copts = COPTS,
  2282. tags = ["team:core"],
  2283. deps = [
  2284. ":gcs",
  2285. "@com_google_googletest//:gtest_main",
  2286. ],
  2287. )
  2288. cc_test(
  2289. name = "asio_test",
  2290. size = "small",
  2291. srcs = ["src/ray/gcs/test/asio_test.cc"],
  2292. args = [
  2293. "$(location redis-server)",
  2294. "$(location redis-cli)",
  2295. ],
  2296. copts = COPTS,
  2297. data = [
  2298. "//:redis-cli",
  2299. "//:redis-server",
  2300. ],
  2301. tags = ["team:core"],
  2302. deps = [
  2303. ":gcs",
  2304. "//src/ray/util",
  2305. "@com_google_googletest//:gtest_main",
  2306. ],
  2307. )
  2308. flatbuffer_cc_library(
  2309. name = "node_manager_fbs",
  2310. srcs = ["src/ray/raylet/format/node_manager.fbs"],
  2311. flatc_args = FLATC_ARGS,
  2312. out_prefix = "ray/raylet/format/",
  2313. )
  2314. pyx_library(
  2315. name = "_raylet",
  2316. srcs = glob([
  2317. "python/ray/__init__.py",
  2318. "python/ray/_raylet.pxd",
  2319. "python/ray/_raylet.pyx",
  2320. "python/ray/includes/*.pxd",
  2321. "python/ray/includes/*.pxi",
  2322. ]),
  2323. # Export ray ABI symbols, which can then be used by _streaming.so.
  2324. # We need to dlopen this lib with RTLD_GLOBAL to use ABI in this
  2325. # shared lib, see python/ray/__init__.py.
  2326. cc_kwargs = dict(
  2327. srcs = PYX_SRCS,
  2328. copts = COPTS + PYX_COPTS,
  2329. # see https://github.com/tensorflow/tensorflow/blob/r2.1/tensorflow/lite/BUILD#L444
  2330. linkopts = select({
  2331. "@bazel_tools//src/conditions:darwin": [
  2332. "-Wl,-exported_symbols_list,$(location //:src/ray/ray_exported_symbols.lds)",
  2333. ],
  2334. "@bazel_tools//src/conditions:windows": [
  2335. ],
  2336. "//conditions:default": [
  2337. "-Wl,--version-script,$(location //:src/ray/ray_version_script.lds)",
  2338. ],
  2339. }),
  2340. linkstatic = 1,
  2341. ),
  2342. deps = [
  2343. "//:core_worker_lib",
  2344. "//:global_state_accessor_lib",
  2345. "//:raylet_lib",
  2346. "//:redis_client",
  2347. "//:src/ray/ray_exported_symbols.lds",
  2348. "//:src/ray/ray_version_script.lds",
  2349. "//:stats_lib",
  2350. "//src/ray/protobuf:serialization_cc_proto",
  2351. "//src/ray/util",
  2352. ],
  2353. )
  2354. cc_binary(
  2355. name = "libcore_worker_library_java.so",
  2356. srcs = glob([
  2357. "src/ray/core_worker/lib/java/*.h",
  2358. "src/ray/core_worker/lib/java/*.cc",
  2359. ]),
  2360. copts = COPTS,
  2361. # Export ray ABI symbols, which can then be used by libstreaming_java.so. see `//:_raylet`
  2362. linkopts = select({
  2363. "@bazel_tools//src/conditions:darwin": [
  2364. "-Wl,-exported_symbols_list,$(location //:src/ray/ray_exported_symbols.lds)",
  2365. ],
  2366. "@bazel_tools//src/conditions:windows": [
  2367. ],
  2368. "//conditions:default": [
  2369. "-Wl,--version-script,$(location //:src/ray/ray_version_script.lds)",
  2370. ],
  2371. }),
  2372. linkshared = 1,
  2373. linkstatic = 1,
  2374. visibility = ["//java:__subpackages__"],
  2375. deps = [
  2376. "//:core_worker_lib",
  2377. "//:global_state_accessor_lib",
  2378. "//:src/ray/ray_exported_symbols.lds",
  2379. "//:src/ray/ray_version_script.lds",
  2380. "//:stats_lib",
  2381. "@bazel_tools//tools/jdk:jni",
  2382. ],
  2383. )
  2384. filegroup(
  2385. name = "python_sources",
  2386. srcs = glob([
  2387. "python/ray/*.py",
  2388. "python/ray/autoscaler/*.py",
  2389. "python/ray/autoscaler/_private/*.py",
  2390. "python/ray/autoscaler/_private/_azure/*.json",
  2391. "python/ray/autoscaler/aws/defaults.yaml",
  2392. "python/ray/autoscaler/azure/defaults.yaml",
  2393. "python/ray/autoscaler/gcp/defaults.yaml",
  2394. "python/ray/autoscaler/local/defaults.yaml",
  2395. "python/ray/cloudpickle/*.py",
  2396. "python/ray/core/__init__.py",
  2397. "python/ray/core/generated/__init__.py",
  2398. "python/ray/core/generated/ray/__init__.py",
  2399. "python/ray/core/generated/ray/protocol/__init__.py",
  2400. "python/ray/dashboard/**/*.py",
  2401. "python/ray/experimental/*.py",
  2402. "python/ray/util/*.py",
  2403. "python/ray/internal/*.py",
  2404. "python/ray/workers/default_worker.py",
  2405. ]),
  2406. )
  2407. alias(
  2408. name = "redis-server",
  2409. actual = select({
  2410. "@bazel_tools//src/conditions:windows": "@com_github_tporadowski_redis_bin//:redis-server.exe",
  2411. "//conditions:default": "@com_github_antirez_redis//:redis-server",
  2412. }),
  2413. visibility = ["//visibility:public"],
  2414. )
  2415. alias(
  2416. name = "redis-cli",
  2417. actual = select({
  2418. "@bazel_tools//src/conditions:windows": "@com_github_tporadowski_redis_bin//:redis-cli.exe",
  2419. "//conditions:default": "@com_github_antirez_redis//:redis-cli",
  2420. }),
  2421. visibility = ["//visibility:public"],
  2422. )
  2423. filegroup(
  2424. name = "all_py_proto",
  2425. srcs = [
  2426. "//src/ray/protobuf:agent_manager_py_proto",
  2427. "//src/ray/protobuf:autoscaler_py_proto",
  2428. "//src/ray/protobuf:common_py_proto",
  2429. "//src/ray/protobuf:core_worker_py_proto",
  2430. "//src/ray/protobuf:event_py_proto",
  2431. "//src/ray/protobuf:gcs_py_proto",
  2432. "//src/ray/protobuf:gcs_service_py_proto",
  2433. "//src/ray/protobuf:instance_manager_py_proto",
  2434. "//src/ray/protobuf:job_agent_py_proto",
  2435. "//src/ray/protobuf:monitor_py_proto",
  2436. "//src/ray/protobuf:node_manager_py_proto",
  2437. "//src/ray/protobuf:ray_client_py_proto",
  2438. "//src/ray/protobuf:reporter_py_proto",
  2439. "//src/ray/protobuf:runtime_env_agent_py_proto",
  2440. "//src/ray/protobuf:runtime_env_common_py_proto",
  2441. "//src/ray/protobuf:usage_py_proto",
  2442. ],
  2443. )
  2444. filegroup(
  2445. name = "serve_py_proto",
  2446. srcs = [
  2447. "//src/ray/protobuf:serve_py_proto",
  2448. ],
  2449. )
  2450. # This is a dummy test dependency that causes the python tests to be
  2451. # re-run if any of these files changes.
  2452. py_library(
  2453. name = "ray_lib",
  2454. srcs = glob(
  2455. ["python/ray/**/*.py"],
  2456. exclude = ["python/ray/tests/*.py"],
  2457. ),
  2458. visibility = ["__subpackages__"],
  2459. )
  2460. copy_to_workspace(
  2461. name = "cp_raylet_so",
  2462. srcs = ["python/ray/_raylet.so"],
  2463. dstdir = "python/ray",
  2464. )
  2465. copy_to_workspace(
  2466. name = "cp_all_py_proto",
  2467. srcs = [":all_py_proto"],
  2468. dstdir = "python/ray/core/generated",
  2469. )
  2470. copy_to_workspace(
  2471. name = "cp_serve_py_proto",
  2472. srcs = [":serve_py_proto"],
  2473. dstdir = "python/ray/serve/generated",
  2474. )
  2475. copy_to_workspace(
  2476. name = "cp_redis",
  2477. srcs = [
  2478. ":redis-cli",
  2479. ":redis-server",
  2480. ],
  2481. dstdir = "python/ray/core/src/ray/thirdparty/redis/src",
  2482. )
  2483. copy_to_workspace(
  2484. name = "cp_raylet",
  2485. srcs = [":raylet"],
  2486. dstdir = "python/ray/core/src/ray/raylet",
  2487. )
  2488. copy_to_workspace(
  2489. name = "cp_gcs_server",
  2490. srcs = [":gcs_server"],
  2491. dstdir = "python/ray/core/src/ray/gcs",
  2492. )
  2493. genrule(
  2494. name = "install_py_proto",
  2495. srcs = [
  2496. ":cp_all_py_proto",
  2497. ":cp_serve_py_proto",
  2498. ],
  2499. outs = ["install_py_proto.out"],
  2500. cmd = """
  2501. # NOTE(hchen): Protobuf doesn't allow specifying Python package name. So we use this `sed`
  2502. # command to change the import path in the generated file.
  2503. # shellcheck disable=SC2006
  2504. files=(
  2505. `ls python/ray/core/generated/*_pb2*.py` \
  2506. `ls python/ray/serve/generated/*_pb2*.py` \
  2507. )
  2508. sed -i -E 's/from src.ray.protobuf/from ./' "$${files[@]}"
  2509. # TODO(sang): Build our own proto instead of creating a new proto for opencensus separately.
  2510. # https://github.com/ray-project/ray/issues/31358
  2511. sed -i -E 's/from opencensus.proto.metrics.v1 import/from . import/' "$${files[@]}"
  2512. sed -i -E 's/from opencensus.proto.resource.v1 import/from . import/' "$${files[@]}"
  2513. # TODO(rickyx): Remove this experimental path rewrite once we move autoscaler proto out
  2514. # of experimental.
  2515. autoscale_files=(`ls python/ray/core/generated/autoscaler_pb2*.py`)
  2516. sed -i -E 's/from ..experimental/from ./' "$${autoscale_files[@]}"
  2517. echo "$${PWD}" > $@
  2518. """,
  2519. local = 1,
  2520. )
  2521. genrule(
  2522. name = "ray_pkg",
  2523. srcs = [
  2524. ":cp_raylet_so",
  2525. ":python_sources",
  2526. ":install_py_proto",
  2527. ":cp_redis",
  2528. ":cp_raylet",
  2529. ":cp_gcs_server",
  2530. ],
  2531. outs = ["ray_pkg.out"],
  2532. cmd = """
  2533. if [ "$${OSTYPE-}" = "msys" ]; then
  2534. ln -P -f -- python/ray/_raylet.so python/ray/_raylet.pyd
  2535. fi
  2536. echo "$${PWD}" > $@
  2537. """,
  2538. local = 1,
  2539. )