overridesuite_id = suite.get_overridesuite().suite_id
- writer = SourcesFileWriter(archive=suite.archive.path, suite=suite.suite_name, component=component.component_name)
+ writer_args = {
+ 'archive': suite.archive.path,
+ 'suite': suite.suite_name,
+ 'component': component.component_name
+ }
+ if suite.indices_compression is not None:
+ writer_args['compression'] = suite.indices_compression
+ writer = SourcesFileWriter(**writer_args)
output = writer.open()
# run query and write Sources
if include_long_description:
metadata_skip.append("Description-md5")
- writer = PackagesFileWriter(archive=suite.archive.path, suite=suite.suite_name,
- component=component.component_name,
- architecture=architecture.arch_string, debtype=type_name)
+ writer_args = {
+ 'archive': suite.archive.path,
+ 'suite': suite.suite_name,
+ 'component': component.component_name,
+ 'architecture': architecture.arch_string,
+ 'debtype': type_name
+ }
+ if suite.indices_compression is not None:
+ writer_args['compression'] = suite.indices_compression
+ writer = PackagesFileWriter(**writer_args)
output = writer.open()
r = session.execute(_packages_query, {"archive_id": suite.archive.archive_id,
suite = session.query(Suite).get(suite_id)
component = session.query(Component).get(component_id)
- writer = TranslationFileWriter(archive=suite.archive.path, suite=suite.suite_name, component=component.component_name, language="en")
+ writer_args = {
+ 'archive': suite.archive.path,
+ 'suite': suite.suite_name,
+ 'component': component.component_name,
+ 'language': 'en',
+ }
+ if suite.i18n_compression is not None:
+ writer_args['compression'] = suite.i18n_compression
+ writer = TranslationFileWriter(**writer_args)
output = writer.open()
r = session.execute(_translations_query, {"suite": suite_id, "component": component_id})
force = Options.has_key("Force") and Options["Force"]
- component_ids = [ c.component_id for c in session.query(Component).all() ]
def parse_results(message):
# Split out into (code, msg)
else:
logger.log(['E: ', msg])
+ # Lock tables so that nobody can change things underneath us
+ session.execute("LOCK TABLE src_associations IN SHARE MODE")
+ session.execute("LOCK TABLE bin_associations IN SHARE MODE")
+
for s in suites:
+ component_ids = [ c.component_id for c in s.components ]
if s.untouchable and not force:
- import utils
- utils.fubar("Refusing to touch %s (untouchable and not forced)" % s.suite_name)
+ import daklib.utils
+ daklib.utils.fubar("Refusing to touch %s (untouchable and not forced)" % s.suite_name)
for c in component_ids:
pool.apply_async(generate_sources, [s.suite_id, c], callback=parse_results)
if not s.include_long_description: