added spawn as global package while importing

example/protobuf/eigr/functions/spawn/example/messages/messages_pb2_grpc.py

@@ -0,0 +1,4 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+

example/protobuf/eigr/functions/spawn/example/state/joe_pb2_grpc.py

@@ -0,0 +1,4 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+

protobuf/eigr/functions/protocol/actors/actor_pb2_grpc.py

@@ -0,0 +1,4 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+

protobuf/eigr/functions/protocol/actors/protocol_pb2_grpc.py

@@ -0,0 +1,4 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+

protobuf/google/protobuf/any_pb2_grpc.py

@@ -0,0 +1,4 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+

spawn/sdk.py

@@ -6,7 +6,7 @@
 
 from dataclasses import dataclass, field
 
-from handler import action_handler
+from spawn.handler import action_handler
 from internal.controller import SpawnActorController as ActorController
 
 from typing import List, Callable, Any, Mapping, MutableMapping
@@ -32,21 +32,24 @@ def init(self) -> ActorParams:
 @dataclass
 class ActorEntity:
     init_state: Callable[[str], Any]
-    command_handlers: MutableMapping[str,
-                                     Callable] = field(default_factory=dict)
+    command_handlers: MutableMapping[str, Callable] = field(default_factory=dict)
 
     def command(self, name: str):
         def register_command_handler(function):
             """
             Register the function to handle commands
             """
             if name in self.command_handlers:
-                raise Exception("Command handler function {} already defined for command {}".format(
-                    self.command_handlers[name], name))
+                raise Exception(
+                    "Command handler function {} already defined for command {}".format(
+                        self.command_handlers[name], name
+                    )
+                )
 
             if function.__code__.co_argcount > 2:
                 raise Exception(
-                    "At most two parameters, the command and the context, should be accepted by the command function")
+                    "At most two parameters, the command and the context, should be accepted by the command function"
+                )
 
             self.command_handlers[name] = function
             return function
@@ -65,16 +68,18 @@ def init_actor(self):
 @dataclass
 class Spawn:
     actorController = ActorController(
-        os.environ.get('PROXY_HOST', 'localhost'),
-        os.environ.get('PROXY_PORT', '9001'),
+        os.environ.get("PROXY_HOST", "localhost"),
+        os.environ.get("PROXY_PORT", "9001"),
     )
 
     logging.basicConfig(
-        format='%(asctime)s - %(filename)s - %(levelname)s: %(message)s', level=logging.INFO)
+        format="%(asctime)s - %(filename)s - %(levelname)s: %(message)s",
+        level=logging.INFO,
+    )
     logging.root.setLevel(logging.NOTSET)
 
-    __host = '127.0.0.1'
-    __port = '8090'
+    __host = "127.0.0.1"
+    __port = "8090"
     __actors: List[ActorEntity] = field(default_factory=list)
 
     def host(self, address: str):
@@ -94,20 +99,20 @@ def register_actor(self, entity: ActorEntity):
 
     def start(self):
         """Start the user function and HTTP Server."""
-        address = '{}:{}'.format(os.environ.get(
-            'HOST', self.__host), os.environ.get('PORT', self.__port))
+        address = "{}:{}".format(
+            os.environ.get("HOST", self.__host), os.environ.get("PORT", self.__port)
+        )
 
-        logging.info('Starting Spawn on address %s', address)
+        logging.info("Starting Spawn on address %s", address)
         try:
             app = Flask(__name__)
             app.register_blueprint(action_handler)
-            app.run(host=self.__host, port=self.__port,
-                    threaded=True, debug=True)
+            app.run(host=self.__host, port=self.__port, threaded=True, debug=True)
 
             # Invoke proxy for register ActorsEntity using Spawn protobuf types
             self.__register(self.__actors)
         except IOError as e:
-            logging.error('Error on start Spawn %s', e.__cause__)
+            logging.error("Error on start Spawn %s", e.__cause__)
 
     def __register(self, actors: List[ActorEntity]):
         self.actorController.register(actors)