(self,
execution_id=None,
user_name=None,
user_id=None,
script_name=None,
command=None,
log_lines=None,
start_time_millis=None,
exit_code=0,
write_post_execution_info=True,
output_format=OUTPUT_FORMAT_TERMINAL,
parameter_configs=None,
parameter_values=None)
| 419 | return content[log_start:] |
| 420 | |
| 421 | def simulate_logging(self, |
| 422 | execution_id=None, |
| 423 | user_name=None, |
| 424 | user_id=None, |
| 425 | script_name=None, |
| 426 | command=None, |
| 427 | log_lines=None, |
| 428 | start_time_millis=None, |
| 429 | exit_code=0, |
| 430 | write_post_execution_info=True, |
| 431 | output_format=OUTPUT_FORMAT_TERMINAL, |
| 432 | parameter_configs=None, |
| 433 | parameter_values=None): |
| 434 | |
| 435 | output_stream = Observable() |
| 436 | |
| 437 | execution_id = self.start_logging(command=command, |
| 438 | execution_id=execution_id, |
| 439 | output_stream=output_stream, |
| 440 | script_name=script_name, |
| 441 | start_time_millis=start_time_millis, |
| 442 | user_id=user_id, |
| 443 | user_name=user_name, |
| 444 | output_format=output_format, |
| 445 | parameter_configs=parameter_configs, |
| 446 | parameter_values=parameter_values) |
| 447 | |
| 448 | if log_lines: |
| 449 | for line in log_lines: |
| 450 | output_stream.push(line + '\n') |
| 451 | |
| 452 | output_stream.close() |
| 453 | |
| 454 | if write_post_execution_info: |
| 455 | self.logging_service.write_post_execution_info(execution_id, exit_code) |
| 456 | |
| 457 | @default_values_decorator |
| 458 | def start_logging(self, |
no test coverage detected