Skip to content
Snippets Groups Projects
  1. Jul 07, 2023
  2. May 12, 2023
  3. Mar 08, 2023
  4. Mar 07, 2023
    • David Douard's avatar
      Refactor the content replayer as a class · 84535c11
      David Douard authored
      this allows to make it actually benefit from multithreading, by not
      sharing objstorage instances between threads.
      
      Note: the doctest formely in process_replay_objects_content's docstring
      has been moved to a proper test in test_replay.py; the required mocking
      to make it work is not suitable for docstring anymore.
      84535c11
  5. Feb 17, 2023
  6. Feb 16, 2023
  7. Feb 02, 2023
  8. Jan 09, 2023
  9. Dec 19, 2022
  10. Dec 16, 2022
  11. Dec 09, 2022
  12. Oct 27, 2022
  13. Oct 18, 2022
  14. Aug 23, 2022
  15. Jun 22, 2022
  16. Jun 21, 2022
  17. May 09, 2022
  18. Apr 26, 2022
  19. Apr 21, 2022
  20. Apr 08, 2022
  21. Apr 06, 2022
  22. Mar 22, 2022
    • Antoine Lambert's avatar
      pytest: Exclude build directory for tests discovery · 37535c3d
      Antoine Lambert authored
      Due to test modules being copied in subdirectories of the
      build directory by setuptools, it makes pytest fail by raising
      ImportPathMismatchError exceptions when invoked from root
      directory of the module.
      
      So ignore the build folder to discover tests.
      37535c3d
  23. Feb 10, 2022
  24. Feb 07, 2022
  25. Jan 21, 2022
  26. Jan 13, 2022
    • David Douard's avatar
      Make the copy process of blob objects run with thread concurrency · 0dffebc4
      David Douard authored
      for each batch of messages, dispatch the copy of individual objects in a
      ThreadPoolExecutor.
      The idea is to allow concurrency to ge beyong process parallelism
      provided by kafka consumer groups. Since the copy a one object is mainly
      IO bound (check existence in destination objstare, retrieve from source
      objstorage, put in destination objstorage) with possibly large delays
      (eg. retrieveing a blob from s3 imply a minimum 150/200ms delay before
      the HTTP request is replied, whatever the size of the object);
      this tries to parallelize those delays.
      0dffebc4
  27. Jan 04, 2022
  28. Dec 16, 2021
  29. Dec 02, 2021
  30. Nov 25, 2021
    • David Douard's avatar
      Small code refactoring in test_cli · 00244356
      David Douard authored
      make '_fill_objstorage_and_kafka()' take the actual objstorage as
      argument, instead of the dict of objstorages ("src", "dst"). The "dst"
      objstorage is not used in the function, and it make the intent of this
      later clearer.
      00244356
  31. Jun 09, 2021
Loading