@@ -540,7 +540,7 @@ def __str__(self):
540540 else :
541541 filter_str = ""
542542 bypass_str = f" bypass_intersecting_intervals_phase={ self .bypass_intersecting_intervals_phase } "
543- return f"workspace={ self .workspace } vidmap={ self .vidmap_file } callset={ self .callset_file } attributes={ self .attributes } { filter_str } { bypass_str } "
543+ return f"workspace={ self .workspace } vidmap={ self .vidmap_file } callset={ self .callset_file } attributes={ self .attributes } { filter_str } { bypass_str } " # noqa
544544
545545
546546class GenomicsDBQueryConfig (NamedTuple ):
@@ -606,6 +606,7 @@ def configure_query(config: GenomicsDBQueryConfig):
606606 query_config .query_row_ranges .extend ([row_range_list ])
607607 return query_config
608608
609+
609610def instantiate_genomicsdb (pb_config , msg ):
610611 logging .info ("Instantiating genomicsdb to process " + msg + "..." )
611612 gdb = genomicsdb .connect_with_protobuf (pb_config )
@@ -635,7 +636,7 @@ def process(config):
635636 logging .info ("Found gdb to process " + msg )
636637 else :
637638 logging .info ("Starting new gdb to process " + msg )
638- gdb = instantiate_genomicsdb (configure_export (export_config ), msg );
639+ gdb = instantiate_genomicsdb (configure_export (export_config ), msg )
639640 except NameError :
640641 gdb = instantiate_genomicsdb (configure_export (export_config ), msg )
641642
@@ -646,7 +647,9 @@ def process(config):
646647 df = gdb .query_variant_calls (query_protobuf = query_protobuf , flatten_intervals = True )
647648 df .to_csv (output_config .filename , index = False )
648649 elif output_config .type == "json" :
649- json_output = gdb .query_variant_calls (query_protobuf = query_protobuf , json_output = output_config .json_type )
650+ json_output = gdb .query_variant_calls (
651+ query_protobuf = query_protobuf , json_output = output_config .json_type
652+ )
650653 with open (output_config .filename , "wb" ) as f :
651654 f .write (json_output )
652655 elif output_config .type == "arrow" :
0 commit comments