<commit_before>from flow.petri_net.future import FutureAction, FutureNet
from flow.shell_command.actions import ForkDispatchAction, LSFDispatchAction
from twisted.internet import defer

import logging


LOG = logging.getLogger(__name__)

class ShellCommandNet(FutureNet):
    def __init__(self, *args, **kwargs):
        FutureNet.__init__(self, *args, **kwargs)

        self.start = self.add_place('start')
        self.success = self.add_place('success')
        self.failure = self.add_place('failure')


class LSFCommandNet(ShellCommandNet):
    def __init__(self, name,
            dispatch_success_action=None,
            dispatch_failure_action=None,
            begin_execute_action=None,
            success_action=None,
            failure_action=None,
            **action_args):

        ShellCommandNet.__init__(self, name)

        self.dispatching = self.add_place("dispatching")
        self.pending = self.add_place("pending")
        self.running = self.add_place("running")
        self.dispatch_success_place = self.add_place("msg: dispatch_success")
        self.dispatch_failure_place = self.add_place("msg: dispatch_failure")<commit_msg>remove unused import in shell_command/future_nets.py<commit_after>from flow.petri_net.future import FutureAction, FutureNet
from flow.shell_command.actions import ForkDispatchAction, LSFDispatchAction

import logging


LOG = logging.getLogger(__name__)


class ShellCommandNet(FutureNet):
    def __init__(self, *args, **kwargs):
        FutureNet.__init__(self, *args, **kwargs)

        self.start = self.add_place('start')
        self.success = self.add_place('success')
        self.failure = self.add_place('failure')


class LSFCommandNet(ShellCommandNet):
    def __init__(self, name,
            dispatch_success_action=None,
            dispatch_failure_action=None,
            begin_execute_action=None,
            success_action=None,
            failure_action=None,
            **action_args):

        ShellCommandNet.__init__(self, name)

        self.dispatching = self.add_place("dispatching")
        self.pending = self.add_place("pending")
        self.running = self.add_place("running")
        self.dispatch_success_place = self.add_place("msg: dispatch_success")
        self.dispatch_failure_place = self.add_place("msg: dispatch_failure")
{'fraction_non_alphanumeric': 0.09918419922713612, 'fraction_numerical': 0.0, 'mean_word_length': 3.4721689059500958, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '1764408', 'n_tokens_mistral': 660, 'n_tokens_neox': 646, 'n_words': 115}