|
11 | 11 |
|
12 | 12 | import peppy |
13 | 13 |
|
14 | | -from geopephub.const import LAST_UPDATE_DATES, BEDBASE_MAX_SIZE |
| 14 | +from geopephub.const import LAST_UPDATE_DATES, BEDBASE_MAX_SIZE, ACCBASE_FINDER_FILTER, ACCBASE_MAX_SIZE |
15 | 15 | from geopephub.utils import get_agent, get_base_db_engine |
16 | 16 | from geopephub.models import StatusModel, CycleModel |
17 | 17 | from geopephub.utils import run_geofetch, add_link_to_description |
@@ -59,6 +59,11 @@ def add_to_queue_by_period( |
59 | 59 | gse_list = geofetch.Finder( |
60 | 60 | filters="((bed) OR narrowPeak) OR broadPeak" |
61 | 61 | ).get_gse_by_date(start_date_str, today_date_str) |
| 62 | + elif target == "accbase": |
| 63 | + # get chromatin accessibility projects (ATAC-seq, scATAC-seq, DNase-seq) |
| 64 | + gse_list = geofetch.Finder( |
| 65 | + filters=ACCBASE_FINDER_FILTER |
| 66 | + ).get_gse_by_date(start_date_str, today_date_str) |
62 | 67 | elif target == "geo": |
63 | 68 | gse_list = geofetch.Finder().get_gse_by_date(start_date_str, today_date_str) |
64 | 69 | else: |
@@ -195,6 +200,14 @@ def _upload_gse_project( |
195 | 200 | data_source="all", |
196 | 201 | processed=True, |
197 | 202 | ) |
| 203 | + elif target == "accbase": |
| 204 | + # For accbase, we want all files from ATAC-seq/DNase-seq projects |
| 205 | + # No file extension filter - we filter by assay type in the Finder |
| 206 | + geofetcher_obj = geofetch.Geofetcher( |
| 207 | + filter_size=ACCBASE_MAX_SIZE, |
| 208 | + data_source="all", |
| 209 | + processed=True, |
| 210 | + ) |
198 | 211 | else: |
199 | 212 | geofetcher_obj = geofetch.Geofetcher() |
200 | 213 | total_nb = len(log_model_dict.keys()) |
@@ -254,6 +267,8 @@ def _upload_gse_project( |
254 | 267 | gse_log.status_info = "pepdbagent" |
255 | 268 | if target == "bedbase": |
256 | 269 | tag = pep_tag |
| 270 | + elif target == "accbase": |
| 271 | + tag = pep_tag |
257 | 272 | else: |
258 | 273 | tag = "default" |
259 | 274 | try: |
|
0 commit comments