Skip to content

Commit

Permalink
Merge pull request #392 from alliance-genome/fix_error_handling
Browse files Browse the repository at this point in the history
Fix error handling
  • Loading branch information
oblodgett authored Mar 15, 2019
2 parents 6f68b8e + ba47847 commit 29384cc
Show file tree
Hide file tree
Showing 4 changed files with 13 additions and 6 deletions.
4 changes: 3 additions & 1 deletion src/aggregate_loader.py
Original file line number Diff line number Diff line change
@@ -1,9 +1,11 @@
import logging, coloredlogs, os, multiprocessing, time, argparse, time

from etl import *
from etl.helpers import Neo4jHelper
from transactors import Neo4jTransactor, FileTransactor
from data_manager import DataFileManager
from common import ContextInfo
from common import ContextInfo # Must be the last timeport othersize program fails


parser = argparse.ArgumentParser(description='Load data into the Neo4j database for the Alliance of Genome Resources.')
parser.add_argument('-c', '--config', help='Specify the filename of the YAML config. It must reside in the src/config/ directory', default='default.yml')
Expand Down
8 changes: 5 additions & 3 deletions src/etl/mi_etl.py
Original file line number Diff line number Diff line change
@@ -1,11 +1,13 @@
import logging
logger = logging.getLogger(__name__)

import urllib, json, sys
import urllib, json

from etl import ETL
from transactors import CSVTransactor, Neo4jTransactor

logger = logging.getLogger(__name__)



class MIETL(ETL):

query_template = """
Expand Down
4 changes: 3 additions & 1 deletion src/transactors/file_transactor.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,9 @@
import logging
import multiprocessing
from time import sleep
from etl import *

from etl import ETL


logger = logging.getLogger(__name__)

Expand Down
3 changes: 2 additions & 1 deletion src/transactors/neo4j_transactor.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,10 +3,11 @@
import os
import pickle
import time
from etl import *

from neo4j.v1 import GraphDatabase

from etl import ETL


logger = logging.getLogger(__name__)

Expand Down

0 comments on commit 29384cc

Please sign in to comment.