-# Get the input file for the task and open it for reading
-with open(arvados.get_task_param_mount('input')) as f:
- while True:
- buf = f.read(2**20) # read a 1 megabyte block from the file
- if len(buf) == 0: # break when there is no more data left
- break
- digestor.update(buf) # update the md5 hash object
+# Get the input file for the task
+input_id, input_path = this_task['parameters']['input'].split('/', 1)