Page MenuHomeSoftware Heritage
Paste P649

(An Untitled Masterwork)
ActivePublic

Authored by seirl on Apr 17 2020, 4:34 PM.
subprocess.run(
("pv {export_path}/*/*.edges.csv.zst | "
"tee graph.edges.csv.zst |"
"zstdcat |"
"tee >( wc -l > graph.edges.count.txt ) |"
"tr ' ' '\\n' | "
"cat - <( zstdcat {export_path}/*/*.nodes.csv.zst | "
" tee >( wc -l > graph.nodes.count.txt ) ) | "
"sort -u -S{sort_buffer_size} -T{buffer_path} | "
"zstdmt > {export_path}/graph.nodes.csv.zst")
.format(
export_path=shlex.quote(export_path),
buffer_path=shlex.quote(buffer_path),
sort_buffer_size=shlex.quote(sort_buffer_size),
),
shell=True,
env=env,
)