Skip to content

file_lock.py

NwbfileLock

Bases: SpyglassMixin, Manual

Source code in src/spyglass/lock/file_lock.py 
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
@schema
class NwbfileLock(SpyglassMixin, dj.Manual):
    definition = """
    -> Nwbfile
    """

    def populate_from_lock_file(self):
        """
        Reads from the NWB_LOCK_FILE (defined by an environment variable),
        adds the entries to this schema, and then removes the file
        """
        if os.path.exists(os.getenv("NWB_LOCK_FILE")):
            lock_file = open(os.getenv("NWB_LOCK_FILE"), "r")
            for line in lock_file:
                logger.info(line)
                key = {"nwb_file_name": line.strip()}
                self.insert1(key, skip_duplicates="True")
            lock_file.close()
            os.remove(os.getenv("NWB_LOCK_FILE"))

populate_from_lock_file()

Reads from the NWB_LOCK_FILE (defined by an environment variable), adds the entries to this schema, and then removes the file

Source code in src/spyglass/lock/file_lock.py 
18
19
20
21
22
23
24
25
26
27
28
29
30
def populate_from_lock_file(self):
    """
    Reads from the NWB_LOCK_FILE (defined by an environment variable),
    adds the entries to this schema, and then removes the file
    """
    if os.path.exists(os.getenv("NWB_LOCK_FILE")):
        lock_file = open(os.getenv("NWB_LOCK_FILE"), "r")
        for line in lock_file:
            logger.info(line)
            key = {"nwb_file_name": line.strip()}
            self.insert1(key, skip_duplicates="True")
        lock_file.close()
        os.remove(os.getenv("NWB_LOCK_FILE"))

AnalysisNwbfileLock

Bases: SpyglassMixin, Manual

Source code in src/spyglass/lock/file_lock.py 
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
@schema
class AnalysisNwbfileLock(SpyglassMixin, dj.Manual):
    definition = """
    -> AnalysisNwbfile
    """

    def populate_from_lock_file(self):
        """Reads/inserts from lock file, then removes lock file.

        Requires ANALYSIS_LOCK_FILE environment variable.
        """

        if os.path.exists(os.getenv("ANALYSIS_LOCK_FILE")):
            lock_file = open(os.getenv("ANALYSIS_LOCK_FILE"), "r")
            for line in lock_file:
                key = {"analysis_file_name": line.strip()}
                self.insert1(key, skip_duplicates="True")
            os.remove(os.getenv("ANALYSIS_LOCK_FILE"))

populate_from_lock_file()

Reads/inserts from lock file, then removes lock file.

Requires ANALYSIS_LOCK_FILE environment variable.

Source code in src/spyglass/lock/file_lock.py 
39
40
41
42
43
44
45
46
47
48
49
50
def populate_from_lock_file(self):
    """Reads/inserts from lock file, then removes lock file.

    Requires ANALYSIS_LOCK_FILE environment variable.
    """

    if os.path.exists(os.getenv("ANALYSIS_LOCK_FILE")):
        lock_file = open(os.getenv("ANALYSIS_LOCK_FILE"), "r")
        for line in lock_file:
            key = {"analysis_file_name": line.strip()}
            self.insert1(key, skip_duplicates="True")
        os.remove(os.getenv("ANALYSIS_LOCK_FILE"))