Adds logging in worker processes

coriolis/db/sqlalchemy/models.py

@@ -17,8 +17,6 @@ class Task(BASE, models.TimestampMixin, models.ModelBase):
     migration_id = sqlalchemy.Column(sqlalchemy.String(36),
                                      sqlalchemy.ForeignKey('migration.id'),
                                      nullable=False)
-    # migration = relationship("Migration",
-    # backref=backref("tasks"), lazy='joined')
     instance = sqlalchemy.Column(sqlalchemy.String(1024), nullable=False)
     host = sqlalchemy.Column(sqlalchemy.String(1024), nullable=True)
     process_id = sqlalchemy.Column(sqlalchemy.Integer, nullable=True)

coriolis/worker/rpc/server.py

@@ -128,6 +128,10 @@ class WorkerServerEndpoint(object):
 def _export_instance(export_provider, connection_info,
                      instance, export_path, mp_q):
     try:
+        # Setting up logging, needed since this is a new process
+        logging.register_options(CONF)
+        logging.setup(CONF, 'coriolis')
+
         vm_info = export_provider.export_instance(
             connection_info, instance, export_path)
         mp_q.put(vm_info)
@@ -139,6 +143,10 @@ def _export_instance(export_provider, connection_info,
 def _import_instance(import_provider, connection_info,
                      target_environment, instance, export_info, mp_q):
     try:
+        # Setting up logging, needed since this is a new process
+        logging.register_options(CONF)
+        logging.setup(CONF, 'coriolis')
+
         import_provider.import_instance(
             connection_info, target_environment, instance, export_info)
         mp_q.put(None)