forked from cov-lineages/pango-designation
-
Notifications
You must be signed in to change notification settings - Fork 0
/
deduplicate_keeping_first.py
44 lines (38 loc) · 1.08 KB
/
deduplicate_keeping_first.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
# Need to install `llist` package for this to work
from llist import dllist
# Read in file from end to start
d = dllist()
with open('lineages.csv', 'r') as f:
for line in f:
d.append(line)
#%%
# Iterate over each line in d from back to front
# Save the string till first comma in hashset
# If string in hashset, delete line
hashset = set()
keep_going=True
next = d.first
while next:
current = next
next = next.next
line = current.value
split = line.split(',')
if line == '\n':
d.remove(current)
continue
if split[0] in hashset:
d.remove(current)
print(f"Removed duplicate strain: {line}")
continue
# Exclude strain names that are not GISAIDy
# strain names must have at least 2 slashes
# This gets rid of things like `strain` or `OX0123456`
if split[0].count('/') < 2 and line != 'taxon,lineage\n':
d.remove(current)
print(f"Removed non-GISAID strain: {line}")
continue
hashset.add(split[0])
#%%
# Write back to file
with open('lineages.csv', 'w') as f:
f.writelines(d)