Skip to content
Snippets Groups Projects
  1. Mar 08, 2022
  2. Dec 08, 2021
  3. Nov 09, 2021
    • David Douard's avatar
      Add support for a redis-based reporting for invalid mirrorred objects · 850a7553
      David Douard authored
      The idea is that we check the BaseModel validity at journal
      deserialization time so that we still have access to the raw object from
      kafka for complete reporting (object id plus raw message from kafka).
      
      This uses a new ModelObjectDeserializer class that is responsible for
      deserializing the kafka message (still using kafka_to_value) then
      immediately create the BaseModel object from that dict. Its `convert`
      method is then passed as `value_deserializer` argument of the
      `JournalClient`.
      
      Then, for each deserialized object from kafka, if it's a HashableObject,
      check its validity by comparing the computed hash with its id.
      
      If it's invalid, report the error in logs, and if configured, register the
      invalid object in via the `reporter` callback.
      
      In the cli code, a `Redis.set()` is used a such a callback (if configured).
      So it simply stores invalid objects using the object id a key (typically its
      swhid), and the raw kafka message value as value.
      
      Related to T3693.
  4. Sep 25, 2020
  5. Sep 10, 2020
  6. Aug 11, 2020
    • vlorentz's avatar
      cassandra: Add annotations to make mypy actually type-check calls to CqlRunner. · 92e7a21e
      vlorentz authored
      All methods of CqlRunner were decorated, which prevented mypy from doing
      anything useful.
      
      As I finally found a way to type the decorator (using
      mypy_extensions.NamedArg), I can finally make mypy aware of the methods' types.
      
      This commit (as well as all three of the last commits) also fixes issues found
      by mypy thanks to this.
      92e7a21e
  7. Aug 07, 2020
  8. Jun 23, 2020
    • David Douard's avatar
      Deprecate the origin_add_one() endpoint · 621fc8d3
      David Douard authored
      This endpoint is not really useful since the origin_add() can be used
      instead.
      
      Using a single API endpoint would also make the API a bit more consistant
      (most other endpoints only provide a xxx_add endpoint) ; having a single
      endpoint per object_type make is enough and make the whole API simpler.
      621fc8d3
  9. Jun 11, 2020
  10. Feb 27, 2020
  11. Jan 31, 2020
  12. Jan 14, 2020
  13. Jan 10, 2020
  14. Oct 11, 2017
  15. Jun 14, 2017
  16. Jun 06, 2017
    • Antoine R. Dumont's avatar
      archiver: Make package work for actual objstorage dependency version · 80944cb1
      Antoine R. Dumont authored
      The head version of the objstorage migrated. Thus the archiver tests
      broke locally.
      
      The test code was fixed to make the local tests pass with the actual
      head version of the objstorage.
      
      But we did not deploy the new objstorage yet, thus the archiver tests
      break during the packaging phase (of any swh.storage.* package).
      
      This commit is a temporary fix to make everyone happy (since we do
      need to package other storage version for example).
      
      This needs to be reverted as soon as we bump the dependency to the new
      objstorage (> 0.17).
      
      Related f681f83c
      Related b4dfe06f
      Related 08827dc5
      Related D205
      Verified
      80944cb1
  17. Mar 23, 2017
  18. Mar 13, 2017
  19. Feb 09, 2017
  20. Jan 26, 2017
  21. Dec 20, 2016
  22. Nov 03, 2016
    • Nicolas Dandrimont's avatar
      storage: add check_config method · 51c4896f
      Nicolas Dandrimont authored
      The check_config method allows a dynamic check of the configuration for
      a running storage. We can make sure that we have proper permissions on
      the object storage as well as the database before running things.
      51c4896f
  23. Sep 22, 2016
  24. Sep 20, 2016
  25. Sep 14, 2016
    • Antoine R. Dumont's avatar
      Archiver Director/Worker: Add copy to backend worker implementation · d0cbf0a5
      Antoine R. Dumont authored
      Actions storage:
      - Open cache_content_get to retrieve contents in cache
      - sql/upgrades/080: Add stored procedure to read contents from cache
      
      Actions archiver:
      - d/control: Add dependency to archiver on python3-swh.objstorage.cloud
      - Renamed Archiver(Director|Worker) to
      ArchiverWithRetentionPolicy(Director|Worker)
      - Add ArchiverToBackend(Director|Worker)
      - Add new celery task dedicated for new workers
      - Update docstring details
      
      Related T555
      Verified
      d0cbf0a5
  26. Aug 23, 2016
  27. Aug 19, 2016
  28. Jul 19, 2016
  29. Jun 27, 2016
  30. Jun 14, 2016
  31. May 19, 2016
  32. Mar 04, 2016
  33. Oct 05, 2015
  34. Oct 01, 2015
  35. Sep 29, 2015
  36. Sep 25, 2015
Loading