Skip to content

Commit

Permalink
Proceeding with refactoring
Browse files Browse the repository at this point in the history
  • Loading branch information
LucaCappelletti94 committed Apr 4, 2020
1 parent d2c9040 commit 7590dcd
Showing 1 changed file with 6 additions and 8 deletions.
14 changes: 6 additions & 8 deletions kg_covid_19/transform_utils/string_ppi/string_ppi.py
Original file line number Diff line number Diff line change
Expand Up @@ -133,7 +133,7 @@ def run(self, data_file: str = None) -> None:
edge_core_header = compress_json.local_load("edge_core_header.json")
edge_additional_headers = compress_json.local_load(
"edge_additional_headers.json")

self.edge_header = edge_core_header + edge_additional_headers
relation = 'RO:0002434'
seen: List = []
Expand Down Expand Up @@ -161,15 +161,15 @@ def run(self, data_file: str = None) -> None:
gene = self.protein_gene_map[protein]
if gene not in seen:
seen.append(gene)
gene_informations=self.gene_info_map[self.ensembl2ncbi_map[gene]]
write_node_edge_item(
fh=node,
header=self.node_header,
data=[
f"ENSEMBL:{gene}",
self.gene_info_map[self.ensembl2ncbi_map[gene]]['symbol'],
gene_informations['symbol'],
'biolink:Gene',
self.gene_info_map[self.ensembl2ncbi_map[gene]
]['description'],
gene_informations['description'],
f"NCBIGene:{self.ensembl2ncbi_map[gene]}"
]
)
Expand All @@ -196,13 +196,11 @@ def run(self, data_file: str = None) -> None:
)

# write edge data
edge_data = [proteins[0], edge_label, proteins[1],
relation, "STRING", items_dict['combined_score']]

write_node_edge_item(
fh=edge,
header=self.edge_header,
data=edge_data + [
data=[proteins[0], edge_label, proteins[1],
relation, "STRING", items_dict['combined_score']] + [
items_dict.get(header, "")
for header in edge_additional_headers
]
Expand Down

0 comments on commit 7590dcd

Please sign in to comment.