diff --git a/daemon/core/emulator/session.py b/daemon/core/emulator/session.py
index e864ec8b..5e3997eb 100644
--- a/daemon/core/emulator/session.py
+++ b/daemon/core/emulator/session.py
@@ -782,6 +782,7 @@ class Session(object):
                 name=name,
                 start=start,
                 image=node_options.image,
+                server=server,
             )
         else:
             node = self.create_node(
diff --git a/daemon/core/nodes/docker.py b/daemon/core/nodes/docker.py
index b91e987e..17d7578a 100644
--- a/daemon/core/nodes/docker.py
+++ b/daemon/core/nodes/docker.py
@@ -89,7 +89,17 @@ class DockerClient(object):
 class DockerNode(CoreNode):
     apitype = NodeTypes.DOCKER.value
 
-    def __init__(self, session, _id=None, name=None, nodedir=None, bootsh="boot.sh", start=True, image=None):
+    def __init__(
+        self,
+        session,
+        _id=None,
+        name=None,
+        nodedir=None,
+        bootsh="boot.sh",
+        start=True,
+        server=None,
+        image=None
+    ):
         """
         Create a DockerNode instance.
 
@@ -99,12 +109,16 @@ class DockerNode(CoreNode):
         :param str nodedir: node directory
         :param str bootsh: boot shell to use
         :param bool start: start flag
+        :param core.emulator.distributed.DistributedServer server: remote server node
+            will run on, default is None for localhost
         :param str image: image to start container with
         """
         if image is None:
             image = "ubuntu"
         self.image = image
-        super(DockerNode, self).__init__(session, _id, name, nodedir, bootsh, start)
+        super(DockerNode, self).__init__(
+            session, _id, name, nodedir, bootsh, start, server
+        )
 
     def create_node_net_client(self, use_ovs):
         """
diff --git a/daemon/core/nodes/lxd.py b/daemon/core/nodes/lxd.py
index eef3dc8f..b11086e7 100644
--- a/daemon/core/nodes/lxd.py
+++ b/daemon/core/nodes/lxd.py
@@ -74,6 +74,7 @@ class LxcNode(CoreNode):
         nodedir=None,
         bootsh="boot.sh",
         start=True,
+        server=None,
         image=None,
     ):
         """
@@ -85,12 +86,16 @@ class LxcNode(CoreNode):
         :param str nodedir: node directory
         :param str bootsh: boot shell to use
         :param bool start: start flag
+        :param core.emulator.distributed.DistributedServer server: remote server node
+            will run on, default is None for localhost
         :param str image: image to start container with
         """
         if image is None:
             image = "ubuntu"
         self.image = image
-        super(LxcNode, self).__init__(session, _id, name, nodedir, bootsh, start)
+        super(LxcNode, self).__init__(
+            session, _id, name, nodedir, bootsh, start, server
+        )
 
     def alive(self):
         """
diff --git a/daemon/examples/python/distributed_lxd.py b/daemon/examples/python/distributed_lxd.py
new file mode 100644
index 00000000..8bafeb7a
--- /dev/null
+++ b/daemon/examples/python/distributed_lxd.py
@@ -0,0 +1,51 @@
+import logging
+import pdb
+import sys
+
+from core.emulator.coreemu import CoreEmu
+from core.emulator.emudata import IpPrefixes, NodeOptions
+from core.emulator.enumerations import EventTypes, NodeTypes
+
+
+def main():
+    address = sys.argv[1]
+    remote = sys.argv[2]
+
+    # ip generator for example
+    prefixes = IpPrefixes(ip4_prefix="10.83.0.0/16")
+
+    # create emulator instance for creating sessions and utility methods
+    coreemu = CoreEmu({"distributed_address": address})
+    session = coreemu.create_session()
+
+    # initialize distributed
+    server_name = "core2"
+    session.add_distributed(server_name, remote)
+
+    # must be in configuration state for nodes to start, when using "node_add" below
+    session.set_state(EventTypes.CONFIGURATION_STATE)
+
+    # create local node, switch, and remote nodes
+    options = NodeOptions(image="ubuntu:18.04")
+    node_one = session.add_node(_type=NodeTypes.LXC, node_options=options)
+    options.emulation_server = server_name
+    node_two = session.add_node(_type=NodeTypes.LXC, node_options=options)
+
+    # create node interfaces and link
+    interface_one = prefixes.create_interface(node_one)
+    interface_two = prefixes.create_interface(node_two)
+    session.add_link(node_one.id, node_two.id, interface_one, interface_two)
+
+    # instantiate session
+    session.instantiate()
+
+    # pause script for verification
+    pdb.set_trace()
+
+    # shutdown session
+    coreemu.shutdown()
+
+
+if __name__ == "__main__":
+    logging.basicConfig(level=logging.INFO)
+    main()