backend/satellite_tools/updatePackages.py | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-)
New commits: commit d00dc3a5efd28f683fd680cabffb7ae969895900 Author: Jan Pazdziora jpazdziora@redhat.com Date: Wed Sep 16 16:23:38 2009 +0200
523384 - break up the transaction into smaller chunks.
diff --git a/backend/satellite_tools/updatePackages.py b/backend/satellite_tools/updatePackages.py index 6ba5492..7b6a575 100644 --- a/backend/satellite_tools/updatePackages.py +++ b/backend/satellite_tools/updatePackages.py @@ -74,9 +74,7 @@ def main():
process_package_data()
- rhnSQL.commit() process_kickstart_trees() - sys.stderr.write("Transaction Committed! \n")
def get_new_pkg_path(nvrea, org_id, prepend="", omit_epoch=None, package_type='rpm', md5sum=None): @@ -136,6 +134,7 @@ def process_package_data(): finalSize=len(paths), finalBarLength=40, stream=sys.stdout) pb.printAll(1) skip_list = [] + i = 0 for path in paths: pb.addTo(1) time.sleep(0.005) @@ -187,8 +186,14 @@ def process_package_data(): # Process gpg key ids server_packages.processPackageKeyAssociations(hdr, md5sum) if debug: Log.writeMessage("gpg key info updated" ) + i = i + 1 + # we need to break the transaction to smaller pieces + if i % 1000 == 0: + rhnSQL.commit() pb.printComplete() - # All done, proceed to commit + # All done, final commit + rhnSQL.commit() + sys.stderr.write("Transaction Committed! \n") if verbose: print " Skipping %s packages, paths not found" % len(skip_list) return
spacewalk-commits@lists.fedorahosted.org