diff --git a/jac-splice-orc/__init__.py b/jac-splice-orc/__init__.py index e69de29bb..697254dc6 100644 --- a/jac-splice-orc/__init__.py +++ b/jac-splice-orc/__init__.py @@ -0,0 +1 @@ +"""Importing required modules and classes.""" diff --git a/jac-splice-orc/grpc_local/__init__.py b/jac-splice-orc/grpc_local/__init__.py index e69de29bb..697254dc6 100644 --- a/jac-splice-orc/grpc_local/__init__.py +++ b/jac-splice-orc/grpc_local/__init__.py @@ -0,0 +1 @@ +"""Importing required modules and classes.""" diff --git a/jac-splice-orc/grpc_local/module_service_pb2.py b/jac-splice-orc/grpc_local/module_service_pb2.py index 10e1214b7..01ef0ca78 100644 --- a/jac-splice-orc/grpc_local/module_service_pb2.py +++ b/jac-splice-orc/grpc_local/module_service_pb2.py @@ -9,32 +9,28 @@ from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder + _runtime_version.ValidateProtobufRuntimeVersion( - _runtime_version.Domain.PUBLIC, - 5, - 27, - 2, - '', - 'module_service.proto' + _runtime_version.Domain.PUBLIC, 5, 27, 2, "", "module_service.proto" ) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() - - -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x14module_service.proto\"2\n\rMethodRequest\x12\x13\n\x0bmethod_name\x18\x01 \x01(\t\x12\x0c\n\x04\x61rgs\x18\x02 \x03(\t\" \n\x0eMethodResponse\x12\x0e\n\x06result\x18\x01 \x01(\t2A\n\rModuleService\x12\x30\n\rExecuteMethod\x12\x0e.MethodRequest\x1a\x0f.MethodResponseb\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile( + b'\n\x14module_service.proto"2\n\rMethodRequest\x12\x13\n\x0bmethod_name\x18\x01 \x01(\t\x12\x0c\n\x04\x61rgs\x18\x02 \x03(\t" \n\x0eMethodResponse\x12\x0e\n\x06result\x18\x01 \x01(\t2A\n\rModuleService\x12\x30\n\rExecuteMethod\x12\x0e.MethodRequest\x1a\x0f.MethodResponseb\x06proto3' +) _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'module_service_pb2', _globals) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, "module_service_pb2", _globals) if not _descriptor._USE_C_DESCRIPTORS: - DESCRIPTOR._loaded_options = None - _globals['_METHODREQUEST']._serialized_start=24 - _globals['_METHODREQUEST']._serialized_end=74 - _globals['_METHODRESPONSE']._serialized_start=76 - _globals['_METHODRESPONSE']._serialized_end=108 - _globals['_MODULESERVICE']._serialized_start=110 - _globals['_MODULESERVICE']._serialized_end=175 + DESCRIPTOR._loaded_options = None + _globals["_METHODREQUEST"]._serialized_start = 24 + _globals["_METHODREQUEST"]._serialized_end = 74 + _globals["_METHODRESPONSE"]._serialized_start = 76 + _globals["_METHODRESPONSE"]._serialized_end = 108 + _globals["_MODULESERVICE"]._serialized_start = 110 + _globals["_MODULESERVICE"]._serialized_end = 175 # @@protoc_insertion_point(module_scope) diff --git a/jac-splice-orc/managers/__init__.py b/jac-splice-orc/managers/__init__.py index e69de29bb..697254dc6 100644 --- a/jac-splice-orc/managers/__init__.py +++ b/jac-splice-orc/managers/__init__.py @@ -0,0 +1 @@ +"""Importing required modules and classes.""" diff --git a/jac-splice-orc/managers/pod_manager_deployment.yml b/jac-splice-orc/managers/pod_manager_deployment.yml index ec26cb7bf..71dae07d2 100644 --- a/jac-splice-orc/managers/pod_manager_deployment.yml +++ b/jac-splice-orc/managers/pod_manager_deployment.yml @@ -14,7 +14,7 @@ metadata: labels: app: pod-manager spec: - replicas: 1 + replicas: 1 selector: matchLabels: app: pod-manager @@ -26,9 +26,9 @@ spec: serviceAccountName: smartimportsa # Use the service account containers: - name: pod-manager - image: ashishmahendra/jac-pod-manager:0.9 + image: ashishmahendra/jac-pod-manager:0.9 ports: - - containerPort: 8000 + - containerPort: 8000 --- @@ -42,6 +42,6 @@ spec: app: pod-manager ports: - protocol: TCP - port: 8000 - targetPort: 8000 - type: LoadBalancer + port: 8000 + targetPort: 8000 + type: LoadBalancer diff --git a/jac-splice-orc/plugin/__init__.py b/jac-splice-orc/plugin/__init__.py index e69de29bb..697254dc6 100644 --- a/jac-splice-orc/plugin/__init__.py +++ b/jac-splice-orc/plugin/__init__.py @@ -0,0 +1 @@ +"""Importing required modules and classes.""" diff --git a/jac-splice-orc/plugin/splice_plugin.py b/jac-splice-orc/plugin/splice_plugin.py index 5e3f6d13b..fd6ffb302 100644 --- a/jac-splice-orc/plugin/splice_plugin.py +++ b/jac-splice-orc/plugin/splice_plugin.py @@ -1,18 +1,23 @@ +"""JAC Splice-Orchestrator Plugin.""" + import types from typing import Optional, Union -from jaclang.plugin.default import hookimpl -from jaclang.plugin.spec import JacBuiltin, JacCmdSpec, JacFeatureSpec, P, T from jaclang.runtimelib.importer import ImportPathSpec, JacImporter, PythonImporter from jaclang.runtimelib.machine import JacMachine, JacProgram from jaclang.settings import settings + from managers.proxy_manager import ModuleProxy + import pluggy + hookimpl = pluggy.HookimplMarker("jac") class SpliceOrcPlugin: + """JAC Splice-Orchestrator Plugin.""" + @staticmethod @hookimpl def jac_import( diff --git a/jac-splice-orc/server/__init__.py b/jac-splice-orc/server/__init__.py index e69de29bb..697254dc6 100644 --- a/jac-splice-orc/server/__init__.py +++ b/jac-splice-orc/server/__init__.py @@ -0,0 +1 @@ +"""Importing required modules and classes.""" diff --git a/jac-splice-orc/test.jac b/jac-splice-orc/test.jac index 60e3eb8b3..e40e84152 100644 --- a/jac-splice-orc/test.jac +++ b/jac-splice-orc/test.jac @@ -1 +1,2 @@ -import:py numpy; \ No newline at end of file +import:py numpy; +import:py pandas; \ No newline at end of file diff --git a/jac-splice-orc/utils/__init__.py b/jac-splice-orc/utils/__init__.py index e69de29bb..697254dc6 100644 --- a/jac-splice-orc/utils/__init__.py +++ b/jac-splice-orc/utils/__init__.py @@ -0,0 +1 @@ +"""Importing required modules and classes."""