def METHOD_NAME(self, task):
    """
    Create a subscription for each task
    """
    workFlow, fileSet = self.createWorkflow(task)
    workFlow.load()
    fileSet.load()
    subType = ''
    if task.name() == 'Processing' or task.name() == 'Production':
        subType = 'Processing'
    elif task.name() == 'Merge':
        subType = 'Merge'
    newSub = Subscription(fileset=fileSet, workflow=workFlow, split_algo='FileBased', type=subType)
    newSub.create()
    # Add subscription to dictionary
    self.subDict[task.name()] = newSub
    # Add subscription id to task
    setattr(task.data.input.WMBS, 'Subscription', newSub['id'])
    if not newSub.exists() >= 0:
        raise Exception("ERROR: Subscription does not exist after it was created")
    logging.info('Created subscription for task %s' % (task.name()))
    return