worker

import time
import sys

group = sys.argv[1]
offset = sys.argv[2]

fo = open('bigfile')
count = 0
for line in fo:
    if count%int(group) == int(offset):
        # supuesto proceso que tarda mucho.
        time.sleep(1)
        # proceso para ver que el archivo resultante fue modificado
        sys.stdout.write(line.replace('*','='))
    count+=1