File: __init__.py

package info (click to toggle)
python-biopython 1.68%2Bdfsg-3~bpo8%2B1
  • links: PTS, VCS
  • area: main
  • in suites: jessie-backports
  • size: 46,856 kB
  • sloc: python: 160,306; xml: 93,216; ansic: 9,118; sql: 1,208; makefile: 155; sh: 63
file content (122 lines) | stat: -rw-r--r-- 3,782 bytes parent folder | download | duplicates (2)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
# Copyright 2007 by Tiago Antao <tiagoantao@gmail.com>.  All rights reserved.
# This code is part of the Biopython distribution and governed by its
# license.  Please see the LICENSE file that should have been included
# as part of this package.

"""Support for asynchronous execution (DEPRECATED)."""

import os
import threading
import warnings

from Bio import BiopythonDeprecationWarning

warnings.warn("Bio.PopGen.Async has been deprecated, and we intend to remove"
              " it in a future release of Biopython. If you would like to"
              " continue using it, please contact the Biopython developers"
              " via the mailing list.", BiopythonDeprecationWarning)


class Async(object):
    """Abstract Asynchronous execution class.

    This is the top abstract class.
    Concrete classes must implement the _run_program method.
    """

    def __init__(self):
        """Async constructor.

        Initializes the queues, among other things.
        Of notice, is the access_ds lock for controlling exclusive
        access to this object.
        """
        self.running = {}
        self.waiting = []
        self.done = {}
        self.id = 0
        self.hooks = {}
        self.access_ds = threading.Lock()

    def run_program(self, program, parameters, input_files):
        """Runs a program.

        Real _run_program to be implemented by concrete classes.

        parameters:
        program String identifying program.
        parameters List of String parameters.
        input_files Hash of Input file descriptors.

        returns:
        Task Id.

        The input_files hash key is the path that is passed
        to the program. It should always be relative.
        Value is a stream.
        """
        if program in self.hooks:
            self.access_ds.acquire()
            self.id += 1
            id = self.id
            self.access_ds.release()
            self._run_program(id, self.hooks[program], parameters, input_files)
            return id

    def _run_program(self, id, program, parameters, input_files):
        """Actually run the program, handled by a subclass (PRIVATE).

        This method should be replaced by any derived class to do
        something useful. It will be called by the run_program method.
        """
        raise NotImplementedError("This object should be subclassed")

    def get_result(self, id):
        """ Returns results for a certain Id, the info for that Id is forgotten.

        parameters:
        id Id of the task.

        returns:
        (return_code, output_files) return code and file access object.

        The output_files hash key is a relative file name, and the value a
        output stream.
        """
        self.access_ds.acquire()
        if id in self.done:
            returnCode, fileObject = self.done[id]
            del self.done[id]
            self.access_ds.release()
        else:
            self.access_ds.release()
            return None


class FileRetriever(object):
    """An Abstract Support class to retrieve files."""

    def __init__(self):
        self.file_list = []

    def get_File_list(self):
        """Returns the list of available files."""
        return self.file_list

    def get_file(self, name):
        raise NotImplementedError('Abstract method')


class DirectoryRetriever(FileRetriever):
    """Retrieves a directory content."""

    def __init__(self, directory):
        FileRetriever.__init__(self)
        self.directory = directory
        walk_list = os.walk(directory)
        for dir, dir_list, file_list in walk_list:
            for file in file_list:
                self.file_list.append(file[len(directory) + 1:])

    def get_file(self, name):
        return open(self.directory + os.sep + name)