diff --git a/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/DynaformsMigrator.php b/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/DynaformsMigrator.php
index bf8c12a16..2afc959ac 100644
--- a/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/DynaformsMigrator.php
+++ b/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/DynaformsMigrator.php
@@ -15,9 +15,9 @@ class DynaformsMigrator implements Importable
     /**
      * DynaformsMigrator constructor.
      */
-    public function __construct(Processes $processes)
+    public function __construct()
     {
-        $this->processes = $processes;
+        $this->processes = new \Processes();
     }
 
     public function beforeImport($data)
diff --git a/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/GranularImporter.php b/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/GranularImporter.php
index 9ae1851c8..ed40f3764 100644
--- a/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/GranularImporter.php
+++ b/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/GranularImporter.php
@@ -19,6 +19,24 @@ class GranularImporter
         $this->factory = new MigratorFactory();
     }
 
+    public function structureBpmnData(array $tables){
+        $project = $tables["project"][0];
+        $diagram = $tables["diagram"][0];
+        $diagram["activities"] = $tables["activity"];
+        $diagram["artifacts"] = (isset($tables["artifact"]))? $tables["artifact"] : array();
+        $diagram["events"] = $tables["event"];
+        $diagram["flows"] = $tables["flow"];
+        $diagram["gateways"] = $tables["gateway"];
+        $diagram["data"] = (isset($tables["data"]))? $tables["data"] : array();
+        $diagram["participants"] = (isset($tables["participant"]))? $tables["participant"] : array();
+        $diagram["laneset"] = (isset($tables["laneset"]))? $tables["laneset"] : array();
+        $diagram["lanes"] = (isset($tables["lane"]))? $tables["lane"] : array();
+        $project["diagrams"] = array($diagram);
+        $project["prj_author"] = isset($this->data["usr_uid"])? $this->data["usr_uid"]: "00000000000000000000000000000001";
+        $project["process"] = $tables["process"][0];
+        return $project;
+    }
+
     public function import($objectList)
     {
         foreach ($objectList as $key => $data) {
diff --git a/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/InputDocumentsMigrator.php b/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/InputDocumentsMigrator.php
index 9804d6379..f4997a1bc 100644
--- a/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/InputDocumentsMigrator.php
+++ b/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/InputDocumentsMigrator.php
@@ -8,9 +8,20 @@
 
 namespace ProcessMaker\BusinessModel\Migrator;
 
+use Symfony\Component\Config\Definition\Exception\Exception;
 
 class InputDocumentsMigrator implements Importable
 {
+    protected $processes;
+
+    /**
+     * DynaformsMigrator constructor.
+     */
+    public function __construct()
+    {
+        $this->processes = new \Processes();
+    }
+
     public function beforeImport($data)
     {
         // TODO: Implement beforeImport() method.
@@ -18,7 +29,11 @@ class InputDocumentsMigrator implements Importable
 
     public function import($data)
     {
-
+        try {
+            $this->processes->createInputRows($data);
+        } catch (\Exception $e) {
+            Logger::log($e);
+        }
     }
 
     public function afterImport($data)
diff --git a/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/OutputDocumentsMigrator.php b/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/OutputDocumentsMigrator.php
index 3811a8bab..ff449ef1e 100644
--- a/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/OutputDocumentsMigrator.php
+++ b/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/OutputDocumentsMigrator.php
@@ -8,9 +8,20 @@
 
 namespace ProcessMaker\BusinessModel\Migrator;
 
+use Symfony\Component\Config\Definition\Exception\Exception;
 
 class OutputDocumentsMigrator implements Importable
 {
+     protected $processes;
+
+    /**
+     * DynaformsMigrator constructor.
+     */
+    public function __construct()
+    {
+        $this->processes = new \Processes();
+    }
+
     public function beforeImport($data)
     {
         // TODO: Implement beforeImport() method.
@@ -18,7 +29,11 @@ class OutputDocumentsMigrator implements Importable
 
     public function import($data)
     {
-
+        try {
+            $this->processes->createOutputRows($data);
+        } catch (\Exception $e) {
+           Logger::log($e);
+        }
     }
 
     public function afterImport($data)
diff --git a/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/ProcessDefinitionMigrator.php b/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/ProcessDefinitionMigrator.php
index feb641bc5..b892cdf8f 100644
--- a/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/ProcessDefinitionMigrator.php
+++ b/workflow/engine/src/ProcessMaker/BusinessModel/Migrator/ProcessDefinitionMigrator.php
@@ -8,9 +8,21 @@
 
 namespace ProcessMaker\BusinessModel\Migrator;
 
+use ProcessMaker\Project\Adapter;
+use Symfony\Component\Config\Definition\Exception\Exception;
 
 class ProcessDefinitionMigrator implements Importable, Exportable
 {
+    protected $bpmn;
+
+    /**
+     * DynaformsMigrator constructor.
+     */
+    public function __construct()
+    {
+        $this->bpmn = new Adapter\BpmnWorkflow();
+    }
+
     public function beforeImport($data)
     {
         // TODO: Implement beforeImport() method.
@@ -18,7 +30,11 @@ class ProcessDefinitionMigrator implements Importable, Exportable
 
     public function import($data)
     {
-        // TODO: Implement import() method.
+        try {
+            $this->bpmn->createFromStruct($data);
+        } catch (\Exception $e) {
+            Logger::log($e);
+        }
     }
 
     public function afterImport($data)