Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[FEAT] Compute pool for native executor #2986

Merged
merged 15 commits into from
Oct 23, 2024

compute runtime for streaming sink

8bb0eb1
Select commit
Loading
Failed to load commit list.
Merged

[FEAT] Compute pool for native executor #2986

compute runtime for streaming sink
8bb0eb1
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch failed Oct 22, 2024 in 1s

77.15% of diff hit (target 78.63%)

View this Pull Request on Codecov

77.15% of diff hit (target 78.63%)

Annotations

Check warning on line 53 in src/common/runtime/src/lib.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/common/runtime/src/lib.rs#L50-L53

Added lines #L50 - L53 were not covered by tests

Check warning on line 55 in src/common/runtime/src/lib.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/common/runtime/src/lib.rs#L55

Added line #L55 was not covered by tests

Check warning on line 60 in src/common/runtime/src/lib.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/common/runtime/src/lib.rs#L57-L60

Added lines #L57 - L60 were not covered by tests

Check warning on line 77 in src/common/runtime/src/lib.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/common/runtime/src/lib.rs#L77

Added line #L77 was not covered by tests

Check warning on line 95 in src/common/runtime/src/lib.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/common/runtime/src/lib.rs#L95

Added line #L95 was not covered by tests

Check warning on line 179 in src/common/runtime/src/lib.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/common/runtime/src/lib.rs#L179

Added line #L179 was not covered by tests

Check warning on line 182 in src/common/runtime/src/lib.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/common/runtime/src/lib.rs#L182

Added line #L182 was not covered by tests

Check warning on line 84 in src/daft-csv/src/metadata.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/daft-csv/src/metadata.rs#L84

Added line #L84 was not covered by tests

Check warning on line 67 in src/daft-io/src/python.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/daft-io/src/python.rs#L67

Added line #L67 was not covered by tests

Check warning on line 81 in src/daft-json/src/schema.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/daft-json/src/schema.rs#L81

Added line #L81 was not covered by tests

Check warning on line 25 in src/daft-local-execution/src/intermediate_ops/intermediate_op.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/daft-local-execution/src/intermediate_ops/intermediate_op.rs#L23-L25

Added lines #L23 - L25 were not covered by tests

Check warning on line 167 in src/daft-local-execution/src/run.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/daft-local-execution/src/run.rs#L166-L167

Added lines #L166 - L167 were not covered by tests

Check warning on line 165 in src/daft-local-execution/src/sources/scan_task.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/daft-local-execution/src/sources/scan_task.rs#L141-L165

Added lines #L141 - L165 were not covered by tests

Check warning on line 168 in src/daft-local-execution/src/sources/scan_task.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/daft-local-execution/src/sources/scan_task.rs#L167-L168

Added lines #L167 - L168 were not covered by tests

Check warning on line 172 in src/daft-local-execution/src/sources/scan_task.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/daft-local-execution/src/sources/scan_task.rs#L171-L172

Added lines #L171 - L172 were not covered by tests

Check warning on line 177 in src/daft-local-execution/src/sources/scan_task.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/daft-local-execution/src/sources/scan_task.rs#L174-L177

Added lines #L174 - L177 were not covered by tests

Check warning on line 181 in src/daft-local-execution/src/sources/scan_task.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/daft-local-execution/src/sources/scan_task.rs#L179-L181

Added lines #L179 - L181 were not covered by tests

Check warning on line 186 in src/daft-local-execution/src/sources/scan_task.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/daft-local-execution/src/sources/scan_task.rs#L184-L186

Added lines #L184 - L186 were not covered by tests

Check warning on line 1019 in src/daft-parquet/src/read.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/daft-parquet/src/read.rs#L1019

Added line #L1019 was not covered by tests