These are chat archives for frictionlessdata/chat
@akariv I'm running into a really confusing issue with
Basically, I made a general flow called
partition, and I want to wrap it in order to partition based on a
def goodtables_partition(source_name, target_name): def func(package: PackageWrapper): source = next((r for r in package if r.res.name == target), None) assert source is not None, ( "cannot validate nonexistent resource %s" % source_name ) report = validator.validate(source) partitioner = build_error_partitioner(report) partition_flow = partition(source_name, target_name, partitioner) return partition_flow(package) return func
partitionseems to work on it's own. Is it maybe some quality of lazy iterators, or an implementation detail that makes the contents of the package empty before
yield package.pkgor something?
get_partitionerargument to avoid building the flow-within-flow
package.pkg) first, and only then the resources are populated.