diff --git a/meshroom/compute.py b/meshroom/compute.py
old mode 100644
new mode 100755
index 34d553aa..a291a563
--- a/meshroom/compute.py
+++ b/meshroom/compute.py
@@ -1,7 +1,7 @@
 #!/usr/bin/env python3
 import argparse
 
-from meshroom import processGraph as pg
+from meshroom.processGraph import graph as pg
 
 parser = argparse.ArgumentParser(description='Execute a Graph of processes.')
 parser.add_argument('graphFile', metavar='GRAPHFILE.mg', type=str,
diff --git a/meshroom/newNodeType.py b/meshroom/newNodeType.py
old mode 100644
new mode 100755
index 6258b069..098d96a5
--- a/meshroom/newNodeType.py
+++ b/meshroom/newNodeType.py
@@ -63,7 +63,7 @@ if sys.stdin.isatty():
 inputCmdLineDoc = ''.join([line for line in sys.stdin])
 
 outputNodeStr = '''
-from processGraph import desc
+from meshroom.processGraph import desc
 
 class __COMMANDNAME__(desc.CommandLineNode):
     internalFolder = '{cache}/{nodeType}/{uid0}/'
diff --git a/meshroom/processGraph/__init__.py b/meshroom/processGraph/__init__.py
index c11239d3..ed2ae061 100644
--- a/meshroom/processGraph/__init__.py
+++ b/meshroom/processGraph/__init__.py
@@ -6,7 +6,6 @@ import tempfile
 from contextlib import contextmanager
 
 from . import desc
-from .graph import *  # TODO: remove this
 
 cacheFolder = os.path.join(tempfile.gettempdir(), 'processGraphCache')
 nodesDesc = {}
diff --git a/meshroom/processGraph/graph.py b/meshroom/processGraph/graph.py
index 32354c87..b8bf28fa 100644
--- a/meshroom/processGraph/graph.py
+++ b/meshroom/processGraph/graph.py
@@ -357,13 +357,13 @@ class Node:
         self.saveStatusFile()
 
     def submit(self):
-        self.upgradeStatusTo(pg.Status.SUBMITTED_EXTERN)
+        self.upgradeStatusTo(Status.SUBMITTED_EXTERN)
 
     def beginSequence(self):
-        self.upgradeStatusTo(pg.Status.SUBMITTED_LOCAL)
+        self.upgradeStatusTo(Status.SUBMITTED_LOCAL)
 
     def process(self):
-        self.upgradeStatusTo(pg.Status.RUNNING)
+        self.upgradeStatusTo(Status.RUNNING)
         statThread = StatisticsThread(self)
         statThread.start()
         try:
@@ -377,15 +377,15 @@ class Node:
                 logContent = ''
                 with open(self.logFile(), 'r') as logF:
                     logContent = ''.join(logF.readlines())
-                self.upgradeStatusTo(pg.Status.ERROR)
+                self.upgradeStatusTo(Status.ERROR)
                 raise RuntimeError('Error on node "{}":\nLog:\n{}'.format(self.name, logContent))
         except:
-            self.upgradeStatusTo(pg.Status.ERROR)
+            self.upgradeStatusTo(Status.ERROR)
             raise
         statThread.running = False
         statThread.join()
 
-        self.upgradeStatusTo(pg.Status.SUCCESS)
+        self.upgradeStatusTo(Status.SUCCESS)
 
     def endSequence(self):
         pass
diff --git a/meshroom/status.py b/meshroom/status.py
old mode 100644
new mode 100755
index 10099e25..2ba2e460
--- a/meshroom/status.py
+++ b/meshroom/status.py
@@ -3,7 +3,7 @@ import argparse
 import os
 from pprint import pprint
 
-from meshroom import processGraph as pg
+from meshroom.processGraph import graph as pg
 
 parser = argparse.ArgumentParser(description='Query the status of nodes in a Graph of processes.')
 parser.add_argument('graphFile', metavar='GRAPHFILE.mg', type=str,