Details

Reviewers

vlorentz

Group Reviewers

Reviewers

Maniphest Tasks

T645: Type swh-storage endpoints with swh.model objects

Commits

rDSTO7beba93a9702: algos.snapshot: Open snapshot_id_get_from_revision

Summary

This leverages the latest change in origin_visit_get and
origin_visit_status_get (paginated endpoints now) to iterate over visits and
visit statuses.
The order iterated over is from most recent to oldest to try and resolve a snapshot targetting
a specific revision.

Note:
This algo got used recently in the deposit. It may serve again.

Depends on D3641
Related to D3645

Related to T645

Test Plan

tox

Diff Detail

Repository

rDSTO Storage manager

Branch

open-snapshot-id

Lint

No Linters Available

Unit

No Unit Test Coverage

Build Status

Buildable 14085
Build 21631: Phabricator diff pipeline on jenkins	Jenkins console · Jenkins
Build 21630: arc lint + arc unit

Event Timeline

ardumont created this revision.Jul 30 2020, 10:02 AM

Herald added a reviewer: Reviewers. · View Herald TranscriptJul 30 2020, 10:02 AM

Build has FAILED

Patch application report for D3648 (id=12839)

Could not rebase; Attempt merge onto 7667f7eef9...

Updating 7667f7ee..2b6635d6
Fast-forward
 swh/storage/algos/snapshot.py            |  55 ++++++++-
 swh/storage/cassandra/cql.py             |  74 +++++++++++
 swh/storage/cassandra/storage.py         |  34 +++++
 swh/storage/db.py                        |  53 ++++----
 swh/storage/in_memory.py                 |  40 ++++++
 swh/storage/interface.py                 |  28 +++++
 swh/storage/storage.py                   |  47 +++++++
 swh/storage/tests/algos/test_snapshot.py |  64 +++++++++-
 swh/storage/tests/test_storage.py        | 205 +++++++++++++++++++++++++++++++
 9 files changed, 569 insertions(+), 31 deletions(-)

Changes applied before test

commit 2b6635d6304c26bcb5f2a7f494caa443399d92f6
Author: Antoine R. Dumont (@ardumont) <ardumont@softwareheritage.org>
Date:   Thu Jul 30 09:58:40 2020 +0200

    algos.snapshot: Open snapshot_get_from_revision
    
    This leverages the latest change in origin_visit_get and
    origin_visit_status_get to iterate over visit and visit status to detect a
    snapshot targetting a revision.
    
    This algo got used recently in the deposit. It may serve again.
    
    Related to T645

commit de11ef60ea74474c16df45149a97e9cfd8244ff0
Author: Antoine R. Dumont (@ardumont) <ardumont@softwareheritage.org>
Date:   Wed Jul 29 16:33:31 2020 +0200

    storage*: add origin_visit_status_get(...) -> PagedResult[OriginVisitStatus]
    
    Related to T645

Link to build: https://jenkins.softwareheritage.org/job/DSTO/job/tests-on-diff/613/
See console output for more information: https://jenkins.softwareheritage.org/job/DSTO/job/tests-on-diff/613/console

Harbormaster failed remote builds in B14075: Diff 12839!Jul 30 2020, 10:10 AM

That's a big function that paginates through two types of objects and iterates through a third type. I think we should break it up, see below

swh/storage/algos/snapshot.py
115–121	move this to a new `iter_origin_visit` generator
122–130	move this to a new `iter_origin_visit_statuses` generator
136	use snapshot_get_all_branches

This revision now requires changes to proceed.Jul 30 2020, 10:14 AM

Update missing branch None case check

and please mention in the docstring it can be a very costly operation

Build is green

Patch application report for D3648 (id=12840)

Could not rebase; Attempt merge onto 7667f7eef9...

Updating 7667f7ee..e026d33d
Fast-forward
 swh/storage/algos/snapshot.py            |  56 ++++++++-
 swh/storage/cassandra/cql.py             |  74 +++++++++++
 swh/storage/cassandra/storage.py         |  34 +++++
 swh/storage/db.py                        |  53 ++++----
 swh/storage/in_memory.py                 |  40 ++++++
 swh/storage/interface.py                 |  28 +++++
 swh/storage/storage.py                   |  47 +++++++
 swh/storage/tests/algos/test_snapshot.py |  64 +++++++++-
 swh/storage/tests/test_storage.py        | 205 +++++++++++++++++++++++++++++++
 9 files changed, 570 insertions(+), 31 deletions(-)

Changes applied before test

commit e026d33d08a488bc73f11f67ac1b8343cec5cc86
Author: Antoine R. Dumont (@ardumont) <ardumont@softwareheritage.org>
Date:   Thu Jul 30 09:58:40 2020 +0200

    algos.snapshot: Open snapshot_get_from_revision
    
    This leverages the latest change in origin_visit_get and
    origin_visit_status_get to iterate over visit and visit status to detect a
    snapshot targetting a revision.
    
    This algo got used recently in the deposit. It may serve again.
    
    Related to T645

commit de11ef60ea74474c16df45149a97e9cfd8244ff0
Author: Antoine R. Dumont (@ardumont) <ardumont@softwareheritage.org>
Date:   Wed Jul 29 16:33:31 2020 +0200

    storage*: add origin_visit_status_get(...) -> PagedResult[OriginVisitStatus]
    
    Related to T645

See https://jenkins.softwareheritage.org/job/DSTO/job/tests-on-diff/614/ for more details.

Harbormaster completed remote builds in B14076: Diff 12840.Jul 30 2020, 10:28 AM

hmm, I think snapshot_id_get_from_revision would be a better name for this function, as it doesn't return the whole snapshot

Adapt according to review:

Rename to snapshot_get_id...
Add docstring warning
Split the main algo using 2 new functions algos.origins.iter_origin_visit(_status)
Add tests to those new functions
use snapshot-get-all-branches

Build is green

Patch application report for D3648 (id=12843)

Could not rebase; Attempt merge onto 7667f7eef9...

Updating 7667f7ee..eb15e9a2
Fast-forward
 swh/storage/algos/origin.py              |  34 ++++-
 swh/storage/algos/snapshot.py            |  47 ++++++-
 swh/storage/cassandra/cql.py             |  74 +++++++++++
 swh/storage/cassandra/storage.py         |  34 +++++
 swh/storage/db.py                        |  53 ++++----
 swh/storage/in_memory.py                 |  40 ++++++
 swh/storage/interface.py                 |  28 +++++
 swh/storage/storage.py                   |  47 +++++++
 swh/storage/tests/algos/test_origin.py   |  88 ++++++++++++-
 swh/storage/tests/algos/test_snapshot.py |  64 +++++++++-
 swh/storage/tests/test_storage.py        | 205 +++++++++++++++++++++++++++++++
 11 files changed, 680 insertions(+), 34 deletions(-)

Changes applied before test

commit eb15e9a29eca90c393a8631562b82e34ba3fe49d
Author: Antoine R. Dumont (@ardumont) <ardumont@softwareheritage.org>
Date:   Thu Jul 30 09:58:40 2020 +0200

    algos.snapshot: Open snapshot_id_get_from_revision
    
    This leverages the latest change in origin_visit_get and
    origin_visit_status_get to iterate over visit and visit status to detect a
    snapshot targetting a revision.
    
    This algo got used recently in the deposit. It may serve again.
    
    Related to T645

commit de11ef60ea74474c16df45149a97e9cfd8244ff0
Author: Antoine R. Dumont (@ardumont) <ardumont@softwareheritage.org>
Date:   Wed Jul 29 16:33:31 2020 +0200

    storage*: add origin_visit_status_get(...) -> PagedResult[OriginVisitStatus]
    
    Related to T645

See https://jenkins.softwareheritage.org/job/DSTO/job/tests-on-diff/616/ for more details.

Harbormaster completed remote builds in B14079: Diff 12843.Jul 30 2020, 11:24 AM

Rebase

ardumont edited the summary of this revision. (Show Details)Jul 30 2020, 12:53 PM

test_origin.py is missing cases where the functions have to paginate. And also cases where there are no results at all

test_origin.py is missing cases where the functions have to paginate. And also cases where there are no results at all

correct... I got side-tracked and forgot about those.

Build is green

Patch application report for D3648 (id=12847)

Could not rebase; Attempt merge onto 7667f7eef9...

Updating 7667f7ee..1a4fa68c
Fast-forward
 swh/storage/algos/origin.py              |  34 +++++-
 swh/storage/algos/snapshot.py            |  47 +++++++-
 swh/storage/cassandra/cql.py             |  76 +++++++++++++
 swh/storage/cassandra/storage.py         |  26 +++++
 swh/storage/db.py                        |  53 +++++----
 swh/storage/in_memory.py                 |  36 +++++++
 swh/storage/interface.py                 |  24 +++++
 swh/storage/storage.py                   |  42 ++++++++
 swh/storage/tests/algos/test_origin.py   |  88 ++++++++++++++-
 swh/storage/tests/algos/test_snapshot.py |  64 ++++++++++-
 swh/storage/tests/test_storage.py        | 177 +++++++++++++++++++++++++++++++
 11 files changed, 633 insertions(+), 34 deletions(-)

Changes applied before test

commit 1a4fa68c77bcc49d189d7739a576ee8c2f9f8966
Author: Antoine R. Dumont (@ardumont) <ardumont@softwareheritage.org>
Date:   Thu Jul 30 09:58:40 2020 +0200

    algos.snapshot: Open snapshot_id_get_from_revision
    
    This leverages the latest change in origin_visit_get and
    origin_visit_status_get to iterate over visit and visit status to detect a
    snapshot targetting a revision.
    
    This algo got used recently in the deposit. It may serve again.
    
    Related to T645

commit 8de3a714051e326a01aa122e6fb09bf081a316cf
Author: Antoine R. Dumont (@ardumont) <ardumont@softwareheritage.org>
Date:   Wed Jul 29 16:33:31 2020 +0200

    storage*: add origin_visit_status_get(...) -> PagedResult[OriginVisitStatus]
    
    Related to T645

See https://jenkins.softwareheritage.org/job/DSTO/job/tests-on-diff/619/ for more details.

Harbormaster completed remote builds in B14083: Diff 12847.Jul 30 2020, 12:58 PM

Rebase on latest master
Add corner cases around test_iter_origin_visit*

Build is green

Patch application report for D3648 (id=12849)

Could not rebase; Attempt merge onto e63b78c6f9...

Updating e63b78c6..9e48e563
Fast-forward
 swh/storage/algos/origin.py              |  34 +++++-
 swh/storage/algos/snapshot.py            |  47 +++++++-
 swh/storage/cassandra/cql.py             |  76 +++++++++++++
 swh/storage/cassandra/storage.py         |  26 +++++
 swh/storage/db.py                        |  53 +++++----
 swh/storage/in_memory.py                 |  36 +++++++
 swh/storage/interface.py                 |  24 +++++
 swh/storage/storage.py                   |  42 ++++++++
 swh/storage/tests/algos/test_origin.py   |  97 ++++++++++++++++-
 swh/storage/tests/algos/test_snapshot.py |  64 ++++++++++-
 swh/storage/tests/test_storage.py        | 177 +++++++++++++++++++++++++++++++
 11 files changed, 642 insertions(+), 34 deletions(-)

Changes applied before test

commit 9e48e5630a7f44061e5be2babd3e35d68fa611ff
Author: Antoine R. Dumont (@ardumont) <ardumont@softwareheritage.org>
Date:   Thu Jul 30 09:58:40 2020 +0200

    algos.snapshot: Open snapshot_id_get_from_revision
    
    This leverages the latest change in origin_visit_get and
    origin_visit_status_get to iterate over visit and visit status to detect a
    snapshot targetting a revision.
    
    This algo got used recently in the deposit. It may serve again.
    
    Related to T645

commit a40a982cf61e2f430cd33456db0fccd522a5d14f
Author: Antoine R. Dumont (@ardumont) <ardumont@softwareheritage.org>
Date:   Wed Jul 29 16:33:31 2020 +0200

    storage*: add origin_visit_status_get(...) -> PagedResult[OriginVisitStatus]
    
    Related to T645

See https://jenkins.softwareheritage.org/job/DSTO/job/tests-on-diff/620/ for more details.

Harbormaster completed remote builds in B14085: Diff 12849.Jul 30 2020, 1:43 PM

vlorentz added inline comments.Jul 30 2020, 1:59 PM

swh/storage/tests/algos/test_origin.py
340–349	The order is confusing, because "reverse_visits" is the list in chronological order. Do this: for visit_id in range(20): visit = OriginVisit( ... date=date_past + datetime.timedelta(days=visit_id), ) visits = swh_storage.origin_visit_add(new_visits) reversed_visits = list(reversed(visits)) And swap visits and reversed_visits in the following lines

Rebase and adapt according to clearer suggestion
@vlorentz quite better thx ^

Build is green

Patch application report for D3648 (id=12854)

Could not rebase; Attempt merge onto 8cf6efa2e6...

Updating 8cf6efa2..7beba93a
Fast-forward
 swh/storage/algos/origin.py              |  34 +++++-
 swh/storage/algos/snapshot.py            |  47 +++++++-
 swh/storage/cassandra/cql.py             |  76 +++++++++++++
 swh/storage/cassandra/storage.py         |  26 +++++
 swh/storage/db.py                        |  53 +++++----
 swh/storage/in_memory.py                 |  36 +++++++
 swh/storage/interface.py                 |  24 +++++
 swh/storage/storage.py                   |  42 ++++++++
 swh/storage/tests/algos/test_origin.py   |  98 ++++++++++++++++-
 swh/storage/tests/algos/test_snapshot.py |  64 ++++++++++-
 swh/storage/tests/test_storage.py        | 177 +++++++++++++++++++++++++++++++
 11 files changed, 643 insertions(+), 34 deletions(-)

Changes applied before test

commit 7beba93a970231e044d48b21491d7c0dbbd43116
Author: Antoine R. Dumont (@ardumont) <ardumont@softwareheritage.org>
Date:   Thu Jul 30 09:58:40 2020 +0200

    algos.snapshot: Open snapshot_id_get_from_revision
    
    This leverages the latest change in origin_visit_get and
    origin_visit_status_get to iterate over visit and visit status to detect a
    snapshot targetting a revision.
    
    This algo got used recently in the deposit. It may serve again.
    
    Related to T645

commit b81f928fa7b941d569bd5d2c9ae8ac7208dbb2c3
Author: Antoine R. Dumont (@ardumont) <ardumont@softwareheritage.org>
Date:   Wed Jul 29 16:33:31 2020 +0200

    storage*: add origin_visit_status_get(...) -> PagedResult[OriginVisitStatus]
    
    Related to T645

See https://jenkins.softwareheritage.org/job/DSTO/job/tests-on-diff/624/ for more details.

Harbormaster completed remote builds in B14090: Diff 12854.Jul 30 2020, 2:19 PM

vlorentz accepted this revision.Jul 30 2020, 3:09 PM

This revision is now accepted and ready to land.Jul 30 2020, 3:09 PM

Closed by commit rDSTO7beba93a9702: algos.snapshot: Open snapshot_id_get_from_revision (authored by ardumont). · Explain WhyJul 30 2020, 3:25 PM

This revision was automatically updated to reflect the committed changes.

ardumont added a commit: rDSTO7beba93a9702: algos.snapshot: Open snapshot_id_get_from_revision.

algos.snapshot: Open snapshot_get_from_revision algorithm
ClosedPublic
Actions

Details

Diff Detail

Event Timeline

Patch application report for D3648 (id=12839)

Changes applied before test

Patch application report for D3648 (id=12840)

Changes applied before test

Patch application report for D3648 (id=12843)

Changes applied before test

Patch application report for D3648 (id=12847)

Changes applied before test

Patch application report for D3648 (id=12849)

Changes applied before test

Patch application report for D3648 (id=12854)

Changes applied before test

Revision Contents
Changeset List

Diff 12849

swh/storage/algos/origin.py

swh/storage/algos/snapshot.py

swh/storage/tests/algos/test_origin.py

swh/storage/tests/algos/test_snapshot.py

algos.snapshot: Open snapshot_get_from_revision algorithmClosedPublicActions

Details

Diff Detail

Event Timeline

Patch application report for D3648 (id=12839)

Changes applied before test

Patch application report for D3648 (id=12840)

Changes applied before test

Patch application report for D3648 (id=12843)

Changes applied before test

Patch application report for D3648 (id=12847)

Changes applied before test

Patch application report for D3648 (id=12849)

Changes applied before test

Patch application report for D3648 (id=12854)

Changes applied before test

Revision ContentsChangeset List

Diff 12849

swh/storage/algos/origin.py

swh/storage/algos/snapshot.py

swh/storage/tests/algos/test_origin.py

swh/storage/tests/algos/test_snapshot.py

algos.snapshot: Open snapshot_get_from_revision algorithm
ClosedPublic
Actions

Revision Contents
Changeset List