remove logger; remove fill_missing flag since there is no image outsi…

…de of the volume bounds

igneous/task_execution.py

@@ -9,7 +9,7 @@
 from taskqueue import TaskQueue
 
 from igneous import EmptyVolumeException
-from igneous import logger
+#from igneous import logger
 
 from igneous.secrets import QUEUE_NAME, QUEUE_TYPE, SQS_URL, LEASE_SECONDS
 
@@ -78,16 +78,19 @@ def execute(tag, queue, server, qurl, loop):
  task.execute()
  print("delete task in queue...")
  tq.delete(task)
- logger.log('INFO', task , "succesfully executed")
+ #logger.log('INFO', task , "succesfully executed")
+ print("successfully executed")
  tries = 0
  except TaskQueue.QueueEmpty:
  time.sleep(random_exponential_window_backoff(tries))
  continue
  except EmptyVolumeException:
- logger.log('WARNING', task, "raised an EmptyVolumeException")
- tq.delete(task)
+ #logger.log('WARNING', task, "raised an EmptyVolumeException")
+ print('raised an EmptyVolumeException')
+ raise 
+ #tq.delete(task)
  except Exception as e:
- logger.log('ERROR', task, "raised {}\n {}".format(e , traceback.format_exc()))
+ #logger.log('ERROR', task, "raised {}\n {}".format(e , traceback.format_exc()))
  raise #this will restart the container in kubernetes
  if (not loop) or (not LOOP):
  print("not in loop mode, will break the loop and exit")

igneous/tasks.py

@@ -1344,8 +1344,8 @@ def _mask_output(self):
  assert np.any(self.output)
 
  def _read_image(self):
- self.image_vol = CloudVolume(self.image_layer_path, bounded=False, 
- fill_missing=False, progress=True, 
+ self.image_vol = CloudVolume(self.image_layer_path, bounded=True, 
+ fill_missing=True, progress=True, 
  mip=self.image_mip, parallel=False)
  output_slices = self.output_bounds.to_slices()
  self.input_slices = tuple(slice(s.start - m, s.stop + m) for s, m in
@@ -1422,8 +1422,8 @@ def _validate_image(self):
  content_type='application/json') 
  raise Exception("detected a black box by template matching!")
 
- validate_vol = CloudVolume(self.image_layer_path, bounded=False, 
- fill_missing=False, progress=True, 
+ validate_vol = CloudVolume(self.image_layer_path, bounded=True, 
+ fill_missing=True, progress=True, 
  mip=self.image_validate_mip, parallel=False)
  validate_image = validate_vol[validate_bbox.to_slices()]
  assert validate_image.shape[3] == 1