equal
deleted
inserted
replaced
931 val timeout_msg = "Timeout after " + job.timeout.message_hms |
931 val timeout_msg = "Timeout after " + job.timeout.message_hms |
932 store.report(job.kind, job.id).progress.echo_error_message(timeout_msg) |
932 store.report(job.kind, job.id).progress.echo_error_message(timeout_msg) |
933 echo(job.name + ": " + timeout_msg) |
933 echo(job.name + ": " + timeout_msg) |
934 } |
934 } |
935 |
935 |
936 val cancelled = for (name <- state.running if _state.running(name).cancelled) yield name |
936 val cancelled = |
937 state.cancel(cancelled) |
937 for { |
|
938 name <- state.running |
|
939 job = _state.running(name) |
|
940 if job.cancelled |
|
941 } yield job |
|
942 |
|
943 cancelled.foreach(job => store.report(job.kind, job.id).progress.echo("Cancelling ...")) |
|
944 state.cancel(cancelled.map(_.name)) |
938 } |
945 } |
939 |
946 |
940 private def finish_job(name: String, process_result: Process_Result): Unit = |
947 private def finish_job(name: String, process_result: Process_Result): Unit = |
941 synchronized_database("finish_job") { |
948 synchronized_database("finish_job") { |
942 val job = _state.running(name) |
949 val job = _state.running(name) |