anchor.diff:          {ok, MasterUrl0} = application:get_env(disco_url),
           MasterUrl = MasterUrl0 ++ disco_server:jobhome(JobName),
   
  +        Debug = os:getenv("DISCO_DEBUG") =/= false,
           spawn_link(NodeAtom, disco_worker, remote_worker,
  -                 [[self(), EventServ, Master, MasterUrl, Task, Node]]),
  +                 [[self(), EventServ, Master, MasterUrl, Task, Node, Debug]]),
           
           receive
                   ok -> ok;
  
positive.code:                                 [Reason1]}})
          end.
  
  init([Id, EventServ, Master, MasterUrl, Task, Node]) ->
          process_flag(trap_exit, true),
          erlang:monitor(process, Task#task.from),
          {ok, #state{id = Id, 
  
negative.code:                     oob = [],
                      oob_counter = 0,
                      errlines = [],
                      debug = Debug,
                      results = []}}.
  
  handle_call(start_worker, _From, S) ->
          Cmd = spawn_cmd(S),
          if S#state.debug ->
                  error_logger:info_report(["Spawn cmd: ", Cmd]);
          true -> ok end,
          Port = open_port({spawn, Cmd}, ?PORT_OPT),
          {reply, ok, S#state{port = Port}, 30000}.
  
  spawn_cmd(#state{task = T, node = Node, master_url = Url}) ->
          lists:flatten(io_lib:fwrite(?CMD,
  