← Back to branch summary

~launchpad-pqm/launchpad/devel

« back to all changes in this revision

Viewing changes to database/replication/initialize.py

  • Committer: Jeroen Vermeulen
  • Date: 2011-09-26 06:30:07 UTC
  • mto: This revision was merged to the branch mainline in revision 14049.
  • Revision ID: jeroen.vermeulen@canonical.com-20110926063007-1fb5eelnidpnra9a
Fix lots of lint in recently-changed files.

Show diffs side-by-side

added added

removed removed

Lines of Context:
database/replication/initialize.py
1
1
#!/usr/bin/python -S
2
2
#
3
 
# Copyright 2009 Canonical Ltd.  This software is licensed under the
 
3
# Copyright 2009-2011 Canonical Ltd.  This software is licensed under the
4
4
# GNU Affero General Public License version 3 (see the file LICENSE).
5
5
 
6
6
"""Initialize the cluster.
9
9
a replicated setup.
10
10
"""
11
11
 
12
 
import _pythonpath
13
 
 
14
12
from optparse import OptionParser
15
13
import subprocess
16
14
import sys
17
15
 
 
16
import _pythonpath
18
17
import helpers
19
18
 
20
19
from canonical.config import config
21
 
from canonical.database.sqlbase import connect, ISOLATION_LEVEL_AUTOCOMMIT
22
20
from canonical.database.postgresql import (
23
 
        all_sequences_in_schema, all_tables_in_schema, ConnectionString
24
 
        )
 
21
    all_sequences_in_schema,
 
22
    all_tables_in_schema,
 
23
    ConnectionString,
 
24
    )
 
25
from canonical.database.sqlbase import (
 
26
    connect,
 
27
    ISOLATION_LEVEL_AUTOCOMMIT,
 
28
    )
25
29
from canonical.launchpad.scripts import (
26
 
        logger, logger_options, db_options
27
 
        )
 
30
    db_options,
 
31
    logger,
 
32
    logger_options,
 
33
    )
 
34
 
28
35
 
29
36
__metaclass__ = type
30
37
__all__ = []
31
38
 
32
39
 
33
 
log = None # Global logger, initialized in main()
34
 
 
35
 
options = None # Parsed command line options, initialized in main()
36
 
 
37
 
cur = None # Shared database cursor to the master, initialized in main()
 
40
# Global logger, initialized in main().
 
41
log = None
 
42
 
 
43
# Parsed command line options, initialized in main().
 
44
options = None
 
45
 
 
46
# Shared database cursor to the master, initialized in main().
 
47
cur = None
38
48
 
39
49
 
40
50
def duplicate_schema():
83
93
 
84
94
def ensure_live():
85
95
    log.info('Ensuring slon daemons are live and propagating events.')
86
 
    helpers.sync(120) # Will exit on failure.
 
96
    # This will exit on failure.
 
97
    helpers.sync(120)
87
98
 
88
99
 
89
100
def create_replication_sets(lpmain_tables, lpmain_sequences):
134
145
        """)
135
146
    helpers.execute_slonik('\n'.join(script), sync=600)
136
147
 
137
 
    helpers.validate_replication(cur) # Explode now if we have messed up.
 
148
    # Explode now if we have messed up.
 
149
    helpers.validate_replication(cur)
138
150
 
139
151
 
140
152
def main():