Handle piped processing from stdin for vector data
We forgot about that when we generalized that for regular data.
@@ -1335,6 +1335,11 @@ class SqliteStore(SqlStore):
with open_to_read(file) as inp:
csvreader = csv.reader(inp, dialect=None, delimiter='\t', quoting=csv.QUOTE_NONE)
+ if self.piped:
+ # header has already been read from stdin, now parse it here:
+ header = io.StringIO(self.piped_header)
+ header = next(csv.reader(header, dialect=None, delimiter='\t', quoting=csv.QUOTE_NONE))
+ else:
header = next(csvreader)
schema = self.kgtk_header_to_graph_table_schema(table, header)
