Added batch identifier to script_run and plugin_run handlers

        conn.create_tunnel(label=label, endpoint=sock)

    @pass_connection

    def script_run(self, conn, sha1, script, owner, *args):

    def script_run(self, conn, sha1, script, owner, batch=None, *args):

        # retrive script if not here

        filename = os.path.join(self.scripts_dir, sha1)

        if not os.access(filename, os.X_OK):

                        'Could not write script to repository: %s', script)

                    raise

        return self.jobs_manager.spawn(ScriptJob, owner, settings=dict(

        return self.jobs_manager.spawn(ScriptJob, owner, batch=batch,

            settings=dict(

                script=script,

                filename=filename,

                args=args,

        plugin.uninstall()

        self.tag_db['__main__']['plugins'].update_value()

    def plugin_run(self, name, method, owner, **kwargs):

    def plugin_run(self, name, method, owner, batch=None, **kwargs):

        if name not in self.plugins:

            raise KeyError('Plugin %r is not running' % name)

        try:

            func = self.plugins[name].methods[method]

        except KeyError:

            raise KeyError('Unknown method %r' % method)

        return self.jobs_manager.spawn(PluginMethodJob, owner, settings=dict(

        return self.jobs_manager.spawn(PluginMethodJob, owner, batch=batch,

            settings=dict(

                plugin_name=name,

                method_name=method,

                method=func,