1
- import { fork } from 'child_process' ;
1
+ import * as child_process from 'child_process' ;
2
2
import { EventEmitter } from 'events' ;
3
- import { defer , Promise } from 'q' ;
4
- import { inherits } from 'util' ;
3
+ import * as q from 'q' ;
5
4
6
5
import { ConfigParser , Config } from './configParser' ;
7
6
import * as Logger from './logger' ;
8
- import TaskLogger from './taskLogger' ;
7
+ import { TaskLogger } from './taskLogger' ;
9
8
10
9
export interface RunResults {
11
10
taskId : number ;
@@ -16,7 +15,7 @@ export interface RunResults {
16
15
specResults : Array < any > ;
17
16
}
18
17
19
- export default class TaskRunner extends EventEmitter {
18
+ export class TaskRunner extends EventEmitter {
20
19
/**
21
20
* A runner for running a specified task (capabilities + specs).
22
21
* The TaskRunner can either run the task from the current process (via
@@ -42,7 +41,7 @@ export default class TaskRunner extends EventEmitter {
42
41
* result of the run:
43
42
* taskId, specs, capabilities, failedCount, exitCode, specResults
44
43
*/
45
- public run ( ) : Promise < any > {
44
+ public run ( ) : q . Promise < any > {
46
45
let runResults : RunResults = {
47
46
taskId : this . task . taskId ,
48
47
specs : this . task . specs ,
@@ -54,9 +53,9 @@ export default class TaskRunner extends EventEmitter {
54
53
} ;
55
54
56
55
if ( this . runInFork ) {
57
- let deferred = defer ( ) ;
56
+ let deferred = q . defer ( ) ;
58
57
59
- let childProcess = fork (
58
+ let childProcess = child_process . fork (
60
59
__dirname + '/runnerCli.js' , process . argv . slice ( 2 ) ,
61
60
{ cwd : process . cwd ( ) , silent : true } ) ;
62
61
let taskLogger = new TaskLogger ( this . task , childProcess . pid ) ;
0 commit comments