Merge lp:~cjwatson/launchpad/copy-set-phase into lp:launchpad

[Colin Watson]

Allow setting the phased-update-percentage for binary publications created by copies.

== Summary ==

Copying packages to the -updates pocket but gradually phasing them in using the phased_update_percentage mechanism effectively requires the PUP to be set to 0 after the copy. However, doing this with BPPH.changeOverride is problematic: it requires archive owner privileges rather than merely the ability to copy, and it's racy because you have to wait for the async copy to complete before you can change its overrides and you have to make sure you squeeze the override change in before the next publisher run. It would be better to be able to specify an initial PUP for the copied binaries. Bug 1192286 has more details.

== Proposed fix ==

Add a phased_update_percentage argument to Archive.copyPackage and propagate it all the way down. The only fiddly bit is choosing exactly how to pass it through PublishingSet.copyBinaries; I opted for making it a parameter you can tweak when creating an override policy, which the policy then remembers and applies as appropriate.

== LOC Rationale ==

+133. This is making an existing feature properly usable so I think it's reasonable; and I have a good track record at removing LoC from LP ...

== Tests ==

bin/test -vvct lp.soyuz.adapters.tests.test_overrides -t lp.soyuz.tests.test_archive -t lp.soyuz.tests.test_packagecopyjob -t lp.soyuz.scripts.tests.test_copypackage -t lp.soyuz.tests.test_publishing -t lp.soyuz.tests.test_packageupload

== Demo and Q/A ==

''Explain how to demonstrate the fix and how to carry out QA on it.''

On DF, pick two packages in PROPOSED pockets but not elsewhere and copy them to UPDATES, one with phased_update_percentage=0 and one with that argument unspecified. Run the publisher. The first should be published with "Phased-Update-Percentage: 0" in Packages, and the second should have that field missing.

[William Grant (wgrant)]

Oops, this slipped under the radar. Looks fine to me, thanks.

review: Approve (code)

=== modified file 'lib/lp/archiveuploader/tests/nascentupload-ddebs.txt'
--- lib/lp/archiveuploader/tests/nascentupload-ddebs.txt	2013-05-24 03:05:34 +0000
+++ lib/lp/archiveuploader/tests/nascentupload-ddebs.txt	2013-06-21 17:17:27 +0000
@@ -81,6 +81,7 @@
 
 We override the binary to main/devel, and accept it into the archive.
 
+    >>> from operator import attrgetter
     >>> from lp.soyuz.interfaces.component import IComponentSet
     >>> from lp.soyuz.interfaces.section import ISectionSet
     >>> main = getUtility(IComponentSet)['main']
@@ -99,7 +100,8 @@
 
     >>> switch_dbuser(config.uploadqueue.dbuser)
 
-    >>> bin_pubs = bin.queue_root.realiseUpload()
+    >>> bin_pubs = sorted(
+    ...     bin.queue_root.realiseUpload(), key=attrgetter('displayname'))
 
     >>> switch_dbuser('uploader')
 
@@ -109,8 +111,8 @@
     ...     print '%s %s %s %s' % (
     ...         bin_pub.displayname, bin_pub.status.name,
     ...         bin_pub.component.name, bin_pub.section.name)
+    debug-bin 1.0-1 in hoary i386 PENDING main devel
     debug-bin-dbgsym 1.0-1 in hoary i386 PENDING main devel
-    debug-bin 1.0-1 in hoary i386 PENDING main devel
 
 DEBs and DDEBs are uploaded to separate archives, because the size
 impact of uploading them to a single archive on mirrors would be
@@ -118,7 +120,7 @@
 
 The DDEB is stored appropriately in the database.
 
-    >>> [ddeb_pub, deb_pub] = bin_pubs
+    >>> [deb_pub, ddeb_pub] = bin_pubs
     >>> ddeb = ddeb_pub.binarypackagerelease
 
     >>> print ddeb.title
 
=== modified file 'lib/lp/soyuz/adapters/overrides.py'
--- lib/lp/soyuz/adapters/overrides.py	2013-06-20 05:50:00 +0000
+++ lib/lp/soyuz/adapters/overrides.py	2013-06-21 17:17:27 +0000
@@ -70,6 +70,8 @@
         "The IDistroArchSeries for the publication")
     priority = Attribute(
         "The PackagePublishingPriority that's being overridden")
+    phased_update_percentage = Attribute(
+        "The phased update percentage that's being overridden")
 
 
 class Override:
@@ -109,11 +111,12 @@
     implements(IBinaryOverride)
 
     def __init__(self, binary_package_name, distro_arch_series, component,
-                 section, priority):
+                 section, priority, phased_update_percentage):
         super(BinaryOverride, self).__init__(component, section)
         self.binary_package_name = binary_package_name
         self.distro_arch_series = distro_arch_series
         self.priority = priority
+        self.phased_update_percentage = phased_update_percentage
 
     def __eq__(self, other):
         return (
@@ -121,13 +124,16 @@
             self.distro_arch_series == other.distro_arch_series and
             self.component == other.component and
             self.section == other.section and
-            self.priority == other.priority)
+            self.priority == other.priority and
+            self.phased_update_percentage == other.phased_update_percentage)
 
     def __repr__(self):
         return ("<BinaryOverride at %x component=%r section=%r "
-            "binary_package_name=%r distro_arch_series=%r priority=%r>" %
+            "binary_package_name=%r distro_arch_series=%r priority=%r "
+            "phased_update_percentage=%r>" %
             (id(self), self.component, self.section, self.binary_package_name,
-             self.distro_arch_series, self.priority))
+             self.distro_arch_series, self.priority,
+             self.phased_update_percentage))
 
 
 class IOverridePolicy(Interface):
@@ -140,6 +146,9 @@
     keep the same component and section as their ancestor publications.
     """
 
+    phased_update_percentage = Attribute(
+        "The phased update percentage to apply to binary publications.")
+
     def calculateSourceOverrides(archive, distroseries, pocket, sources,
                                  source_component=None):
         """Calculate source overrides.
@@ -173,6 +182,10 @@
 
     implements(IOverridePolicy)
 
+    def __init__(self, phased_update_percentage=None):
+        super(BaseOverridePolicy, self).__init__()
+        self.phased_update_percentage = phased_update_percentage
+
     def calculateSourceOverrides(self, archive, distroseries, pocket,
                                  sources, source_component=None):
         raise NotImplementedError()
@@ -245,6 +258,8 @@
             for bpn, das in expanded if das is not None]
         if len(candidates) == 0:
             return []
+        # Do not copy phased_update_percentage from existing publications;
+        # it is too context-dependent to copy.
         already_published = DecoratedResultSet(
             store.find(
                 (BinaryPackagePublishingHistory.binarypackagenameID,
@@ -269,7 +284,9 @@
                 None)),
             pre_iter_hook=eager_load)
         return [
-            BinaryOverride(name, das, component, section, priority)
+            BinaryOverride(
+                name, das, component, section, priority,
+                self.phased_update_percentage)
             for name, das, component, section, priority in already_published]
 
 
@@ -324,7 +341,9 @@
         default_component = archive.default_component or getUtility(
             IComponentSet)['universe']
         return [
-            BinaryOverride(binary, das, default_component, None, None)
+            BinaryOverride(
+                binary, das, default_component, None, None,
+                self.phased_update_percentage)
             for binary, das in calculate_target_das(distroseries, binaries)]
 
 
 
=== modified file 'lib/lp/soyuz/adapters/tests/test_overrides.py'
--- lib/lp/soyuz/adapters/tests/test_overrides.py	2013-05-23 07:06:42 +0000
+++ lib/lp/soyuz/adapters/tests/test_overrides.py	2013-06-21 17:17:27 +0000
@@ -1,4 +1,4 @@
-# Copyright 2011 Canonical Ltd.  This software is licensed under the
+# Copyright 2011-2013 Canonical Ltd.  This software is licensed under the
 # GNU Affero General Public License version 3 (see the file LICENSE).
 
 """Test generic override policy classes."""
@@ -124,7 +124,7 @@
             BinaryOverride(
                 bpph.binarypackagerelease.binarypackagename,
                 bpph.distroarchseries, bpph.component, bpph.section,
-                bpph.priority)]
+                bpph.priority, None)]
         self.assertEqual(expected, overrides)
 
     def test_binary_overrides_constant_query_count(self):
@@ -203,7 +203,7 @@
         expected = [
             BinaryOverride(
                 bpph.binarypackagerelease.binarypackagename,
-                bpph.distroarchseries, universe, None, None)]
+                bpph.distroarchseries, universe, None, None, None)]
         self.assertEqual(expected, overrides)
 
     def test_ubuntu_override_policy_sources(self):
@@ -259,13 +259,14 @@
             expected.append(
                 BinaryOverride(
                     bpn, distroarchseries, bpph.component, bpph.section,
-                    bpph.priority))
+                    bpph.priority, None))
         for i in xrange(2):
             distroarchseries = self.factory.makeDistroArchSeries(
                 distroseries=distroseries)
             bpns.append((bpn, distroarchseries.architecturetag))
             expected.append(
-                BinaryOverride(bpn, distroarchseries, universe, None, None))
+                BinaryOverride(
+                    bpn, distroarchseries, universe, None, None, None))
         distroseries.nominatedarchindep = distroarchseries
         policy = UbuntuOverridePolicy()
         overrides = policy.calculateBinaryOverrides(
@@ -294,3 +295,43 @@
             distroseries.main_archive, distroseries, pocket, ((bpn, 'i386'),))
 
         self.assertEqual([], overrides)
+
+    def test_phased_update_percentage(self):
+        # A policy with a phased_update_percentage applies it to new binary
+        # overrides.
+        universe = getUtility(IComponentSet)['universe']
+        distroseries = self.factory.makeDistroSeries()
+        pocket = self.factory.getAnyPocket()
+        bpn = self.factory.makeBinaryPackageName()
+        bpns = []
+        expected = []
+        distroarchseries = self.factory.makeDistroArchSeries(
+            distroseries=distroseries)
+        bpb = self.factory.makeBinaryPackageBuild(
+            distroarchseries=distroarchseries)
+        bpr = self.factory.makeBinaryPackageRelease(
+            build=bpb, binarypackagename=bpn, architecturespecific=True)
+        bpph = self.factory.makeBinaryPackagePublishingHistory(
+            binarypackagerelease=bpr, distroarchseries=distroarchseries,
+            archive=distroseries.main_archive, pocket=pocket)
+        bpns.append((bpn, distroarchseries.architecturetag))
+        expected.append(
+            BinaryOverride(
+                bpn, distroarchseries, bpph.component, bpph.section,
+                bpph.priority, 50))
+        distroarchseries = self.factory.makeDistroArchSeries(
+            distroseries=distroseries)
+        bpns.append((bpn, distroarchseries.architecturetag))
+        expected.append(
+            BinaryOverride(bpn, distroarchseries, universe, None, None, 50))
+        distroseries.nominatedarchindep = distroarchseries
+        policy = UbuntuOverridePolicy(phased_update_percentage=50)
+        overrides = policy.calculateBinaryOverrides(
+            distroseries.main_archive, distroseries, pocket, bpns)
+        self.assertEqual(2, len(overrides))
+        key = attrgetter("binary_package_name.name",
+            "distro_arch_series.architecturetag",
+            "component.name")
+        sorted_expected = sorted(expected, key=key)
+        sorted_overrides = sorted(overrides, key=key)
+        self.assertEqual(sorted_expected, sorted_overrides)
 
=== modified file 'lib/lp/soyuz/interfaces/archive.py'
--- lib/lp/soyuz/interfaces/archive.py	2013-05-24 04:49:14 +0000
+++ lib/lp/soyuz/interfaces/archive.py	2013-06-21 17:17:27 +0000
@@ -1042,7 +1042,7 @@
     def getPockets():
         """Return iterable containing valid pocket names for this archive."""
 
-    def getOverridePolicy():
+    def getOverridePolicy(phased_update_percentage=None):
         """Returns an instantiated `IOverridePolicy` for the archive."""
 
     buildd_secret = TextLine(
@@ -1356,13 +1356,20 @@
         from_pocket=TextLine(title=_("Source pocket name"), required=False),
         from_series=TextLine(
             title=_("Source distroseries name"), required=False),
+        phased_update_percentage=Int(
+            title=_("Phased update percentage"),
+            description=_("The percentage of users for whom this package"
+                          " should be recommended, or None to publish the"
+                          " update for everyone."),
+            required=False),
         )
     @export_write_operation()
     @operation_for_version('devel')
     def copyPackage(source_name, version, from_archive, to_pocket,
                     person, to_series=None, include_binaries=False,
                     sponsored=None, unembargo=False, auto_approve=False,
-                    from_pocket=None, from_series=None):
+                    from_pocket=None, from_series=None,
+                    phased_update_percentage=None):
         """Copy a single named source into this archive.
 
         Asynchronously copy a specific version of a named source to the
@@ -1393,6 +1400,8 @@
             copy from any pocket with a matching version.
         :param from_series: the source distroseries (as a string). If
             omitted, copy from any series with a matching version.
+        :param phased_update_percentage: the phased update percentage to
+            apply to the copied publication.
 
         :raises NoSuchSourcePackageName: if the source name is invalid
         :raises PocketNotFound: if the pocket name is invalid
 
=== modified file 'lib/lp/soyuz/interfaces/packagecopyjob.py'
--- lib/lp/soyuz/interfaces/packagecopyjob.py	2012-10-23 12:36:50 +0000
+++ lib/lp/soyuz/interfaces/packagecopyjob.py	2013-06-21 17:17:27 +0000
@@ -1,4 +1,4 @@
-# Copyright 2010-2012 Canonical Ltd.  This software is licensed under the
+# Copyright 2010-2013 Canonical Ltd.  This software is licensed under the
 # GNU Affero General Public License version 3 (see the file LICENSE).
 
 __metaclass__ = type
@@ -129,7 +129,8 @@
                include_binaries=False, package_version=None,
                copy_policy=PackageCopyPolicy.INSECURE, requester=None,
                sponsored=None, unembargo=False, auto_approve=False,
-               source_distroseries=None, source_pocket=None):
+               source_distroseries=None, source_pocket=None,
+               phased_update_percentage=None):
         """Create a new `IPlainPackageCopyJob`.
 
         :param package_name: The name of the source package to copy.
@@ -157,6 +158,8 @@
         :param source_pocket: The pocket from which to copy the packages.
             Must be a member of `PackagePublishingPocket`. If omitted, copy
             from any pocket with a matching version.
+        :param phased_update_percentage: The phased update percentage to
+            apply to the copied publication.
         """
 
     def createMultiple(target_distroseries, copy_tasks, requester,
@@ -242,6 +245,9 @@
         title=_("Source package publishing pocket"), required=False,
         readonly=True)
 
+    phased_update_percentage = Int(
+        title=_("Phased update percentage"), required=False, readonly=True)
+
     def addSourceOverride(override):
         """Add an `ISourceOverride` to the metadata."""
 
 
=== modified file 'lib/lp/soyuz/interfaces/publishing.py'
--- lib/lp/soyuz/interfaces/publishing.py	2013-05-31 04:00:53 +0000
+++ lib/lp/soyuz/interfaces/publishing.py	2013-06-21 17:17:27 +0000
@@ -991,7 +991,7 @@
         :param pocket: The target `PackagePublishingPocket`.
         :param binaries: A dict mapping `BinaryPackageReleases` to their
             desired overrides as (`Component`, `Section`,
-            `PackagePublishingPriority`) tuples.
+            `PackagePublishingPriority`, `phased_update_percentage`) tuples.
 
         :return: A list of new `IBinaryPackagePublishingHistory` records.
         """
 
=== modified file 'lib/lp/soyuz/model/archive.py'
--- lib/lp/soyuz/model/archive.py	2013-06-20 05:50:00 +0000
+++ lib/lp/soyuz/model/archive.py	2013-06-21 17:17:27 +0000
@@ -1635,9 +1635,17 @@
     def copyPackage(self, source_name, version, from_archive, to_pocket,
                     person, to_series=None, include_binaries=False,
                     sponsored=None, unembargo=False, auto_approve=False,
-                    from_pocket=None, from_series=None):
+                    from_pocket=None, from_series=None,
+                    phased_update_percentage=None):
         """See `IArchive`."""
         # Asynchronously copy a package using the job system.
+        if phased_update_percentage is not None:
+            if phased_update_percentage < 0 or phased_update_percentage > 100:
+                raise ValueError(
+                    "phased_update_percentage must be between 0 and 100 "
+                    "(inclusive).")
+            elif phased_update_percentage == 100:
+                phased_update_percentage = None
         pocket = self._text_to_pocket(to_pocket)
         series = self._text_to_series(to_series)
         if from_pocket:
@@ -1663,7 +1671,8 @@
             copy_policy=PackageCopyPolicy.INSECURE, requester=person,
             sponsored=sponsored, unembargo=unembargo,
             auto_approve=auto_approve, source_distroseries=from_series,
-            source_pocket=from_pocket)
+            source_pocket=from_pocket,
+            phased_update_percentage=phased_update_percentage)
 
     def copyPackages(self, source_names, from_archive, to_pocket,
                      person, to_series=None, from_series=None,
@@ -1996,14 +2005,15 @@
         # understandiung EnumItems.
         return list(PackagePublishingPocket.items)
 
-    def getOverridePolicy(self):
+    def getOverridePolicy(self, phased_update_percentage=None):
         """See `IArchive`."""
         # Circular imports.
         from lp.soyuz.adapters.overrides import UbuntuOverridePolicy
         # XXX StevenK: bug=785004 2011-05-19 Return PPAOverridePolicy() for
         # a PPA that overrides the component/pocket to main/RELEASE.
         if self.purpose in MAIN_ARCHIVE_PURPOSES:
-            return UbuntuOverridePolicy()
+            return UbuntuOverridePolicy(
+                phased_update_percentage=phased_update_percentage)
         return None
 
     def removeCopyNotification(self, job_id):
 
=== modified file 'lib/lp/soyuz/model/packagecopyjob.py'
--- lib/lp/soyuz/model/packagecopyjob.py	2013-06-20 05:50:00 +0000
+++ lib/lp/soyuz/model/packagecopyjob.py	2013-06-21 17:17:27 +0000
@@ -272,7 +272,7 @@
     def _makeMetadata(cls, target_pocket, package_version,
                       include_binaries, sponsored=None, unembargo=False,
                       auto_approve=False, source_distroseries=None,
-                      source_pocket=None):
+                      source_pocket=None, phased_update_percentage=None):
         """Produce a metadata dict for this job."""
         return {
             'target_pocket': target_pocket.value,
@@ -284,6 +284,7 @@
             'source_distroseries':
                 source_distroseries.name if source_distroseries else None,
             'source_pocket': source_pocket.value if source_pocket else None,
+            'phased_update_percentage': phased_update_percentage,
         }
 
     @classmethod
@@ -292,13 +293,15 @@
                include_binaries=False, package_version=None,
                copy_policy=PackageCopyPolicy.INSECURE, requester=None,
                sponsored=None, unembargo=False, auto_approve=False,
-               source_distroseries=None, source_pocket=None):
+               source_distroseries=None, source_pocket=None,
+               phased_update_percentage=None):
         """See `IPlainPackageCopyJobSource`."""
         assert package_version is not None, "No package version specified."
         assert requester is not None, "No requester specified."
         metadata = cls._makeMetadata(
             target_pocket, package_version, include_binaries, sponsored,
-            unembargo, auto_approve, source_distroseries, source_pocket)
+            unembargo, auto_approve, source_distroseries, source_pocket,
+            phased_update_percentage)
         job = PackageCopyJob(
             job_type=cls.class_job_type,
             source_archive=source_archive,
@@ -451,6 +454,10 @@
             return None
         return PackagePublishingPocket.items[name]
 
+    @property
+    def phased_update_percentage(self):
+        return self.metadata.get('phased_update_percentage')
+
     def _createPackageUpload(self, unapproved=False):
         pu = self.target_distroseries.createQueueEntry(
             pocket=self.target_pocket, archive=self.target_archive,
 
=== modified file 'lib/lp/soyuz/model/publishing.py'
--- lib/lp/soyuz/model/publishing.py	2013-06-21 02:49:33 +0000
+++ lib/lp/soyuz/model/publishing.py	2013-06-21 17:17:27 +0000
@@ -1445,20 +1445,18 @@
             return []
 
         BPPH = BinaryPackagePublishingHistory
-        # XXX cjwatson 2013-02-13: We do not currently set the
-        # phased_update_percentage here.  However, it might be useful in
-        # future to be able to copy a package from PROPOSED to UPDATES and
-        # immediately set its phased_update_percentage to zero; this should
-        # perhaps be an option.
         return bulk.create(
             (BPPH.archive, BPPH.distroarchseries, BPPH.pocket,
              BPPH.binarypackagerelease, BPPH.binarypackagename,
-             BPPH.component, BPPH.section, BPPH.priority, BPPH.status,
-             BPPH.datecreated),
+             BPPH.component, BPPH.section, BPPH.priority,
+             BPPH.phased_update_percentage, BPPH.status, BPPH.datecreated),
             [(archive, das, pocket, bpr, bpr.binarypackagename,
               get_component(archive, das.distroseries, component),
-              section, priority, PackagePublishingStatus.PENDING, UTC_NOW)
-              for (das, bpr, (component, section, priority)) in needed],
+              section, priority, phased_update_percentage,
+              PackagePublishingStatus.PENDING, UTC_NOW)
+              for (das, bpr,
+                   (component, section, priority,
+                    phased_update_percentage)) in needed],
             get_objects=True)
 
     def copyBinaries(self, archive, distroseries, pocket, bpphs, policy=None):
@@ -1500,7 +1498,14 @@
                 new_component = override.component or bpph.component
                 new_section = override.section or bpph.section
                 new_priority = override.priority or bpph.priority
-                calculated = (new_component, new_section, new_priority)
+                # No "or bpph.phased_update_percentage" here; if the
+                # override doesn't specify one then we leave it at None
+                # (a.k.a. 100% of users).
+                new_phased_update_percentage = (
+                    override.phased_update_percentage)
+                calculated = (
+                    new_component, new_section, new_priority,
+                    new_phased_update_percentage)
                 with_overrides[bpph.binarypackagerelease] = calculated
 
                 # If there is a corresponding DDEB then give it our
@@ -1514,7 +1519,7 @@
         else:
             with_overrides = dict(
                 (bpph.binarypackagerelease, (bpph.component, bpph.section,
-                 bpph.priority)) for bpph in bpphs)
+                 bpph.priority, None)) for bpph in bpphs)
         if not with_overrides:
             return list()
         return self.publishBinaries(
 
=== modified file 'lib/lp/soyuz/model/queue.py'
--- lib/lp/soyuz/model/queue.py	2013-06-20 05:50:00 +0000
+++ lib/lp/soyuz/model/queue.py	2013-06-21 17:17:27 +0000
@@ -1207,7 +1207,8 @@
                 binary.version,
                 'Specific' if binary.architecturespecific else 'Independent',
                 ))
-            bins[binary] = (binary.component, binary.section, binary.priority)
+            bins[binary] = (
+                binary.component, binary.section, binary.priority, None)
         return getUtility(IPublishingSet).publishBinaries(
             self.packageupload.archive, distroseries,
             self.packageupload.pocket, bins)
 
=== modified file 'lib/lp/soyuz/scripts/packagecopier.py'
--- lib/lp/soyuz/scripts/packagecopier.py	2013-06-21 02:39:33 +0000
+++ lib/lp/soyuz/scripts/packagecopier.py	2013-06-21 17:17:27 +0000
@@ -506,7 +506,8 @@
             person=None, check_permissions=True, overrides=None,
             send_email=False, strict_binaries=True, close_bugs=True,
             create_dsd_job=True, announce_from_person=None, sponsored=None,
-            packageupload=None, unembargo=False, logger=None):
+            packageupload=None, unembargo=False, phased_update_percentage=None,
+            logger=None):
     """Perform the complete copy of the given sources incrementally.
 
     Verifies if each copy can be performed using `CopyChecker` and
@@ -553,6 +554,8 @@
     :param unembargo: If True, allow copying restricted files from a private
         archive to a public archive, and unrestrict their library files when
         doing so.
+    :param phased_update_percentage: The phased update percentage to apply
+        to the copied publication.
     :param logger: An optional logger.
 
     :raise CannotCopy when one or more copies were not allowed. The error
@@ -628,7 +631,8 @@
             source, archive, destination_series, pocket, include_binaries,
             override, close_bugs=close_bugs, create_dsd_job=create_dsd_job,
             close_bugs_since_version=old_version, creator=creator,
-            sponsor=sponsor, packageupload=packageupload, logger=logger)
+            sponsor=sponsor, packageupload=packageupload,
+            phased_update_percentage=phased_update_percentage, logger=logger)
         if send_email:
             notify(
                 person, source.sourcepackagerelease, [], [], archive,
@@ -655,7 +659,8 @@
 def _do_direct_copy(source, archive, series, pocket, include_binaries,
                     override=None, close_bugs=True, create_dsd_job=True,
                     close_bugs_since_version=None, creator=None,
-                    sponsor=None, packageupload=None, logger=None):
+                    sponsor=None, packageupload=None,
+                    phased_update_percentage=None, logger=None):
     """Copy publishing records to another location.
 
     Copy each item of the given list of `SourcePackagePublishingHistory`
@@ -685,6 +690,8 @@
     :param sponsor: the sponsor `IPerson`, if this copy is being sponsored.
     :param packageupload: The `IPackageUpload` that caused this publication
         to be created.
+    :param phased_update_percentage: The phased update percentage to apply
+        to the copied publication.
     :param logger: An optional logger.
 
     :return: a list of `ISourcePackagePublishingHistory` and
@@ -703,7 +710,8 @@
         version=source.sourcepackagerelease.version,
         status=active_publishing_status,
         distroseries=series, pocket=pocket)
-    policy = archive.getOverridePolicy()
+    policy = archive.getOverridePolicy(
+        phased_update_percentage=phased_update_percentage)
     if source_in_destination.is_empty():
         # If no manual overrides were specified and the archive has an
         # override policy then use that policy to get overrides.
 
=== modified file 'lib/lp/soyuz/scripts/tests/test_copypackage.py'
--- lib/lp/soyuz/scripts/tests/test_copypackage.py	2013-05-29 07:24:13 +0000
+++ lib/lp/soyuz/scripts/tests/test_copypackage.py	2013-06-21 17:17:27 +0000
@@ -1380,6 +1380,27 @@
             section=override.section)
         self.assertThat(copied_source, matcher)
 
+    def test_copy_with_phased_update_percentage(self):
+        # Test the phased_update_percentage parameter for do_copy.
+        nobby, archive, source = self._setup_archive(
+            use_nobby=True, pocket=PackagePublishingPocket.PROPOSED)
+        [bin_i386, bin_hppa] = self.test_publisher.getPubBinaries(
+            pub_source=source, distroseries=nobby,
+            pocket=PackagePublishingPocket.PROPOSED)
+        transaction.commit()
+        switch_dbuser('archivepublisher')
+        [copied_source, copied_bin_i386, copied_bin_hppa] = do_copy(
+            [source], archive, nobby, PackagePublishingPocket.UPDATES,
+            include_binaries=True, check_permissions=False)
+        self.assertIsNone(copied_bin_i386.phased_update_percentage)
+        self.assertIsNone(copied_bin_hppa.phased_update_percentage)
+        [copied_source, copied_bin_i386, copied_bin_hppa] = do_copy(
+            [source], archive, nobby, PackagePublishingPocket.BACKPORTS,
+            include_binaries=True, check_permissions=False,
+            phased_update_percentage=50)
+        self.assertEqual(50, copied_bin_i386.phased_update_percentage)
+        self.assertEqual(50, copied_bin_hppa.phased_update_percentage)
+
     def test_copy_ppa_generates_notification(self):
         # When a copy into a PPA is performed, a notification is sent.
         nobby, archive, source = self._setup_archive()
 
=== modified file 'lib/lp/soyuz/stories/soyuz/xx-person-packages.txt'
--- lib/lp/soyuz/stories/soyuz/xx-person-packages.txt	2013-06-20 05:50:00 +0000
+++ lib/lp/soyuz/stories/soyuz/xx-person-packages.txt	2013-06-21 17:17:27 +0000
@@ -189,9 +189,11 @@
 Create some new source packages, source1 and source2, both created by cprov
 so that they appear in his +packages page.
 
+    >>> from storm.expr import SQL
     >>> from zope.component import getUtility
     >>> from lp.registry.interfaces.distribution import IDistributionSet
     >>> from lp.registry.interfaces.person import IPersonSet
+    >>> from lp.services.database.constants import UTC_NOW
     >>> from lp.soyuz.tests.test_publishing import SoyuzTestPublisher
     >>> from lp.soyuz.enums import PackagePublishingStatus
 
@@ -207,7 +209,8 @@
     >>> source1 = test_publisher.getPubSource(
     ...     status=PackagePublishingStatus.PUBLISHED,
     ...     sourcename='source1',
-    ...     archive=cprov.archive)
+    ...     archive=cprov.archive,
+    ...     date_uploaded=UTC_NOW - SQL("INTERVAL '1 second'"))
     >>> source1.sourcepackagerelease.creator=cprov
     >>> source1_mark = source1.copyTo(
     ...     source1.distroseries, source1.pocket, mark.archive)
@@ -260,17 +263,17 @@
     >>> nopriv_browser = setupBrowser(auth="Basic [e-mail]:test")
     >>> nopriv_browser.open("http://launchpad.dev/~cprov/+related-packages")
     >>> print_ppa_rows(nopriv_browser)
+    source2 PPA named p3a for No Priv... Ubuntutest Breezy-autotest 666
+        ...ago None
     source1 PPA for Celso Providelo - Ubuntutest Breezy-autotest 666
         ...ago None
-    source2 PPA named p3a for No Priv... Ubuntutest Breezy-autotest 666
-        ...ago None
 
     >>> admin_browser.open("http://launchpad.dev/~cprov/+related-packages")
     >>> print_ppa_rows(admin_browser)
+    source2 PPA named p3a for No Priv... Ubuntutest Breezy-autotest 666
+        ...ago None
     source1 PPA for Celso Providelo - Ubuntutest Breezy-autotest 666
         ...ago None
-    source2 PPA named p3a for No Priv... Ubuntutest Breezy-autotest 666
-        ...ago None
 
 Let's move the publication of source1 from mark's public archive to his
 private one and the view the page again.
 
=== modified file 'lib/lp/soyuz/tests/test_archive.py'
--- lib/lp/soyuz/tests/test_archive.py	2013-06-20 05:50:00 +0000
+++ lib/lp/soyuz/tests/test_archive.py	2013-06-21 17:17:27 +0000
@@ -2154,7 +2154,8 @@
             target_archive.copyPackage(
                 source_name, version, source_archive, to_pocket.name,
                 to_series=to_series.name, include_binaries=False,
-                person=target_archive.owner, sponsored=sponsored)
+                person=target_archive.owner, sponsored=sponsored,
+                phased_update_percentage=30)
 
         # The source should not be published yet in the target_archive.
         published = target_archive.getPublishedSources(
@@ -2175,7 +2176,8 @@
             target_pocket=to_pocket,
             include_binaries=False,
             sponsored=sponsored,
-            copy_policy=PackageCopyPolicy.INSECURE))
+            copy_policy=PackageCopyPolicy.INSECURE,
+            phased_update_percentage=30))
 
     def test_copyPackage_disallows_non_primary_archive_uploaders(self):
         # If copying to a primary archive and you're not an uploader for
 
=== modified file 'lib/lp/soyuz/tests/test_packagecopyjob.py'
--- lib/lp/soyuz/tests/test_packagecopyjob.py	2013-06-20 05:50:00 +0000
+++ lib/lp/soyuz/tests/test_packagecopyjob.py	2013-06-21 17:17:27 +0000
@@ -206,7 +206,8 @@
             target_pocket=PackagePublishingPocket.RELEASE,
             package_version="1.0-1", include_binaries=False,
             copy_policy=PackageCopyPolicy.MASS_SYNC,
-            requester=requester, sponsored=sponsored)
+            requester=requester, sponsored=sponsored,
+            phased_update_percentage=20)
         self.assertProvides(job, IPackageCopyJob)
         self.assertEqual(archive1.id, job.source_archive_id)
         self.assertEqual(archive1, job.source_archive)
@@ -220,6 +221,7 @@
         self.assertEqual(PackageCopyPolicy.MASS_SYNC, job.copy_policy)
         self.assertEqual(requester, job.requester)
         self.assertEqual(sponsored, job.sponsored)
+        self.assertEqual(20, job.phased_update_percentage)
 
     def test_createMultiple_creates_one_job_per_copy(self):
         mother = self.factory.makeDistroSeriesParent()
 
=== modified file 'lib/lp/soyuz/tests/test_publishing.py'
--- lib/lp/soyuz/tests/test_publishing.py	2013-05-17 02:40:30 +0000
+++ lib/lp/soyuz/tests/test_publishing.py	2013-06-21 17:17:27 +0000
@@ -1422,7 +1422,7 @@
             'binaries': dict(
                 (bpr, (self.factory.makeComponent(),
                  self.factory.makeSection(),
-                 PackagePublishingPriority.REQUIRED)) for bpr in bprs),
+                 PackagePublishingPriority.REQUIRED, 50)) for bpr in bprs),
             }
 
     def test_architecture_dependent(self):
@@ -1445,7 +1445,9 @@
             (args['archive'], target_das, args['pocket']),
             (bpph.archive, bpph.distroarchseries, bpph.pocket))
         self.assertEqual(
-            overrides, (bpph.component, bpph.section, bpph.priority))
+            overrides,
+            (bpph.component, bpph.section, bpph.priority,
+             bpph.phased_update_percentage))
         self.assertEqual(PackagePublishingStatus.PENDING, bpph.status)
 
     def test_architecture_independent(self):
 
=== modified file 'lib/lp/testing/factory.py'
--- lib/lp/testing/factory.py	2013-06-20 05:50:00 +0000
+++ lib/lp/testing/factory.py	2013-06-21 17:17:27 +0000
@@ -3809,7 +3809,7 @@
             archive, distroarchseries.distroseries, pocket,
             {binarypackagerelease: (
                 binarypackagerelease.component, binarypackagerelease.section,
-                priority)})
+                priority, None)})
         for bpph in bpphs:
             naked_bpph = removeSecurityProxy(bpph)
             naked_bpph.status = status