fix up wandb sync

wandb · Aug 26, 2020 · b79e586 · b79e586
1 parent 657190b
commit b79e586
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/wandb/sdk/wandb_run.py b/wandb/sdk/wandb_run.py
@@ -1114,7 +1114,7 @@ def _on_final(self):
             wandb.termlog("You can sync this run to the cloud by running:")
             wandb.termlog(
                 click.style(
-                    "wandb sync {}".format(self._settings._sync_dir), fg="yellow"
+                    "wandb sync {}".format(self._settings.sync_file), fg="yellow"
                 )
             )
 

diff --git a/wandb/sdk_py27/wandb_run.py b/wandb/sdk_py27/wandb_run.py
@@ -1114,7 +1114,7 @@ def _on_final(self):
             wandb.termlog("You can sync this run to the cloud by running:")
             wandb.termlog(
                 click.style(
-                    "wandb sync {}".format(self._settings._sync_dir), fg="yellow"
+                    "wandb sync {}".format(self._settings.sync_file), fg="yellow"
                 )
             )
 

diff --git a/wandb/sync/sync.py b/wandb/sync/sync.py
@@ -13,6 +13,7 @@
 from six.moves import queue
 from six.moves.urllib.parse import quote as url_quote
 import wandb
+from wandb.interface import interface
 from wandb.internal import datastore
 from wandb.internal import sender
 from wandb.internal import settings_static
@@ -52,8 +53,10 @@ def run(self):
             settings = settings_static.SettingsStatic(sd)
             record_q = queue.Queue()
             result_q = queue.Queue()
+            publish_interface = interface.BackendSender(record_q=record_q)
             sm = sender.SendManager(
-                settings=settings, record_q=record_q, result_q=result_q)
+                settings=settings, record_q=record_q, result_q=result_q,
+                interface=publish_interface)
             ds = datastore.DataStore()
             ds.open_for_scan(sync_item)
             while True: