Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(8)  |  Call(8)  |  Derive(0)  |  Import(0)
Put the task to the executor thread associated to the project name.
If the thread does not exist, it will be created.

src/b/a/baboon-0.1.4/baboon/baboond/transport.py   baboon(Download)
 
        # Add the GitInitTask to the list of tasks to execute.
        dispatcher.put(node, git_init_task)
 
    def _on_rsync_stanza(self, iq):
        from task import RsyncTask
        rsync_task = RsyncTask(sid, rid, sfrom, node, project_path, files)
        dispatcher.put(node, rsync_task)
 
        # Register the current rsync_task in the pending_rsyncs dict.
        # Prepare the merge verification with this data.
        from task import MergeTask
        dispatcher.put(node, MergeTask(node, sfrom))
 
        # Reply to the request.

src/b/a/baboon-HEAD/baboon/baboond/transport.py   baboon(Download)
 
        # Add the GitInitTask to the list of tasks to execute.
        dispatcher.put(node, git_init_task)
 
    def _on_rsync_stanza(self, iq):
        from task import RsyncTask
        rsync_task = RsyncTask(sid, rid, sfrom, node, project_path, files)
        dispatcher.put(node, rsync_task)
 
        # Register the current rsync_task in the pending_rsyncs dict.
        # Prepare the merge verification with this data.
        from task import MergeTask
        dispatcher.put(node, MergeTask(node, sfrom))
 
        # Reply to the request.

src/b/a/baboon-0.1.4/baboon/baboond/task.py   baboon(Download)
        """
 
        dispatcher.put(project_name, AlertTask(project_name, username,
                                               dest_username, merge_conflict,
                                               conflict_files=conflict_files))

src/b/a/baboon-HEAD/baboon/baboond/task.py   baboon(Download)
        """
 
        dispatcher.put(project_name, AlertTask(project_name, username,
                                               dest_username, merge_conflict,
                                               conflict_files=conflict_files))