Skip to content
This repository was archived by the owner on Aug 11, 2020. It is now read-only.

Commit fb5d5e4

Browse files
committed
tweak: Incorporate feedback from @kossak.
1 parent 662902f commit fb5d5e4

File tree

3 files changed

+31
-31
lines changed

3 files changed

+31
-31
lines changed

paperspace/cli/experiments.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -273,7 +273,7 @@ def create_and_start_multi_node(ctx, api_key, show_logs, **kwargs):
273273
experiments_api = client.API(config.CONFIG_EXPERIMENTS_HOST, api_key=api_key)
274274
command = experiments_commands.CreateAndStartExperimentCommand(api=experiments_api)
275275
experiment = command.execute(kwargs)
276-
if experiment is not None and show_logs is True:
276+
if experiment and show_logs:
277277
ctx.invoke(list_logs, experiment_id=experiment["handle"], line=0, limit=100, follow=True, api_key=api_key)
278278

279279

@@ -288,7 +288,7 @@ def create_and_start_single_node(ctx, api_key, show_logs, **kwargs):
288288
experiments_api = client.API(config.CONFIG_EXPERIMENTS_HOST, api_key=api_key)
289289
command = experiments_commands.CreateAndStartExperimentCommand(api=experiments_api)
290290
experiment = command.execute(kwargs)
291-
if experiment is not None and show_logs is True:
291+
if experiment and show_logs:
292292
ctx.invoke(list_logs, experiment_id=experiment["handle"], line=0, limit=100, follow=True, api_key=api_key)
293293

294294

@@ -300,7 +300,7 @@ def create_and_start_single_node(ctx, api_key, show_logs, **kwargs):
300300
def start_experiment(ctx, experiment_id, show_logs, api_key):
301301
experiments_api = client.API(config.CONFIG_EXPERIMENTS_HOST, api_key=api_key)
302302
experiments_commands.start_experiment(experiment_id, api=experiments_api)
303-
if show_logs is True:
303+
if show_logs:
304304
ctx.invoke(list_logs, experiment_id=experiment_id, line=0, limit=100, follow=True, api_key=api_key)
305305

306306

paperspace/commands/experiments.py

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -221,23 +221,23 @@ def _get_logs(self, experiment_id, line, limit):
221221

222222
def _log_logs_list(self, data, table, table_data, follow):
223223
if not data:
224-
self.logger.log("No Logs found")
224+
self.logger.log("No logs found")
225+
return
226+
if follow:
227+
# TODO track number of jobs seen to look for PSEOF
228+
if data[-1].get("message") == "PSEOF":
229+
self.is_logs_complete = True
230+
else:
231+
self.last_line_number = data[-1].get("line")
232+
for log in data:
233+
log_str = "{}\t{}\t{}"
234+
self.logger.log(log_str.format(style(fg="blue", text=str(log.get("jobId"))), style(fg="red", text=str(log.get("line"))), log.get("message")))
225235
else:
226-
if follow:
227-
# TODO track number of jobs seen to look for PSEOF
228-
if data[-1].get("message") == "PSEOF":
229-
self.is_logs_complete = True
230-
else:
231-
self.last_line_number = data[-1].get("line")
232-
for log in data:
233-
log_str = "{}\t{}\t{}"
234-
self.logger.log(log_str.format(style(fg="blue", text=str(log.get("jobId"))), style(fg="red", text=str(log.get("line"))), log.get("message")))
236+
table_str = self._make_table(data, table, table_data)
237+
if len(table_str.splitlines()) > get_terminal_lines():
238+
pydoc.pager(table_str)
235239
else:
236-
table_str = self._make_table(data, table, table_data)
237-
if len(table_str.splitlines()) > get_terminal_lines():
238-
pydoc.pager(table_str)
239-
else:
240-
self.logger.log(table_str)
240+
self.logger.log(table_str)
241241

242242
def _make_table(self, logs, table, table_data):
243243
if logs[-1].get("message") == "PSEOF":

paperspace/commands/jobs.py

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -115,21 +115,21 @@ def _get_logs(self, job_id, line, limit):
115115
def _log_logs_list(self, data, table, table_data, follow):
116116
if not data:
117117
self.logger.log("No Logs found")
118+
return
119+
if follow:
120+
if data[-1].get("message") == "PSEOF":
121+
self.is_logs_complete = True
122+
else:
123+
self.last_line_number = data[-1].get("line")
124+
for log in data:
125+
log_str = "{}\t{}\t{}"
126+
self.logger.log(log_str.format(style(fg="blue", text=str(log.get("jobId"))), style(fg="red", text=str(log.get("line"))), log.get("message")))
118127
else:
119-
if follow:
120-
if data[-1].get("message") == "PSEOF":
121-
self.is_logs_complete = True
122-
else:
123-
self.last_line_number = data[-1].get("line")
124-
for log in data:
125-
log_str = "{}\t{}\t{}"
126-
self.logger.log(log_str.format(style(fg="blue", text=str(log.get("jobId"))), style(fg="red", text=str(log.get("line"))), log.get("message")))
128+
table_str = self._make_table(data, table, table_data)
129+
if len(table_str.splitlines()) > get_terminal_lines():
130+
pydoc.pager(table_str)
127131
else:
128-
table_str = self._make_table(data, table, table_data)
129-
if len(table_str.splitlines()) > get_terminal_lines():
130-
pydoc.pager(table_str)
131-
else:
132-
self.logger.log(table_str)
132+
self.logger.log(table_str)
133133

134134
def _make_table(self, logs, table, table_data):
135135
if logs[-1].get("message") == "PSEOF":

0 commit comments

Comments
 (0)