|
1 | | -from inspirehep.search.api import JobsSearch |
2 | | -from inspirehep.curation.search_check_do import SearchCheckDo |
| 1 | +apiVersion: kustomize.config.k8s.io/v1beta1 |
| 2 | +kind: Kustomization |
3 | 3 |
|
| 4 | +resources: |
| 5 | + - ../../base/script-job |
4 | 6 |
|
5 | | -class FixLegacyJobsDeadlines(SearchCheckDo): |
6 | | - """Fix legacy jobs with fake 'deadline_date=3000'""" |
7 | | - |
8 | | - search_class = JobsSearch |
9 | | - query = "deadline_date:3000" |
10 | | - |
11 | | - @staticmethod |
12 | | - def check(record, logger, state): |
13 | | - has_deadline_3000 = record.get("deadline_date") == 3000 |
14 | | - if has_deadline_3000: |
15 | | - return True |
16 | | - return False |
17 | | - |
18 | | - @staticmethod |
19 | | - def do(record, logger, state): |
20 | | - legacy_version = record.query.get("legacy_version") |
21 | | - if legacy_version: |
22 | | - year, month, day = ( |
23 | | - legacy_version[:4], |
24 | | - legacy_version[4:6], |
25 | | - legacy_version[6:8], |
26 | | - ) |
27 | | - date = f"{year}-{month}-{day}" |
28 | | - record["deadline_date"] = date |
29 | | - record.setdefault("_private_notes", []).append( |
30 | | - { |
31 | | - "value": "Record with no deadline," |
32 | | - " fake 'deadline_date' derived from 'legacy_version'" |
33 | | - } |
34 | | - ) |
35 | | - else: |
36 | | - record["deadline_date"] = record["legacy_creation_date"] |
37 | | - record.setdefault("_private_notes", []).append( |
38 | | - { |
39 | | - "value": "Record with no deadline," |
40 | | - " fake 'deadline_date' derived from 'legacy_creation_date'" |
41 | | - } |
42 | | - ) |
43 | | - |
44 | | - |
45 | | -FixLegacyJobsDeadlines() |
| 7 | +configMapGenerator: |
| 8 | + - name: hep-script |
| 9 | + files: |
| 10 | + - script.py |
0 commit comments