8,656 questions
1
vote
1
answer
46
views
XCom limit of 1024 in airflow
I am hitting the 1024 item limit in the size of a returned list in my task in airflow. I am currently on airflow v2.11. A simple bit of code that reproduces the issue I see is below.
import os, ...
1
vote
1
answer
164
views
Why task cancellation does not work in my code?
I have a code that creates qr-code in MainThread after user's typing. To prevent generation after each small change I tried to create kind of timer with Task.Delay and CancellationToken that could be ...
0
votes
0
answers
144
views
esp32 dmx packet having spikes on signal
I am trying to create a dmx signal using uart on an esp32 (s3).
I have almost achieved the correct signal but on the output, sometimes there are weird spikes in the signal which I'm showing here in ...
1
vote
1
answer
81
views
Why does the NetworkStream.ReadAsync call end the loop
I have a Task that should continuously read from a Tcp stream and place the data into a ConcurrentQueue for processing. Stepping through the function I notice that the ReadAsync Call does not return.
...
1
vote
2
answers
48
views
Airflow tasks in sequence: dag file is parsed again?
I'm writing a DAG script for Apache Airflow and I'm running into behaviour that I didn't expect. If you take a look at my example script I was expecting the same timestamp to be printed. Instead, when ...
1
vote
4
answers
188
views
Why can’t threads freed by Task.Run in ASP.NET Core be immediately reused to handle new HTTP requests?
I’m building an ASP.NET Core Web API hosted on Kestrel. Incoming HTTP requests are dispatched to the ThreadPool, which picks an available thread to execute my controller action. Inside that action, I ...
-1
votes
1
answer
85
views
In a System Verilog FSM can a repetitive State be converted to a Task?
I'm writing an FPGA state machine in System Verilog to read bytes from a SPI port and parse them into commands to the FPGA. The "RXSPIBITS" state is used to read SPI bytes by multiple other ...
2
votes
1
answer
220
views
Awaiting a TaskCompletionSource from two threads
I got curious about what would happen if you await a TaskCompletionSource from two threads.
using System.Diagnostics;
var t = Start();
var t1 = Task.Run(async () => {
await t;
Thread.Sleep(...
1
vote
0
answers
101
views
How to cancel a gRPC client streaming call cleanly without triggering RpcException, ObjectDisposedException, or InvalidOperationException?
I'm working on a gRPC client that continuously streams data (such as images) from a server. I use a CancellationToken to stop the stream when needed. While cancellation works, I consistently see ...
2
votes
0
answers
60
views
Persistent parallel threads in Panda3d, with args at runtime
I'm writing a physics game, and I'm trying to speed up my motion calculations. Every tick of the update cycle, I call an rk4 routine which calls an ODE function 4 times, passing updated values for dt/...
0
votes
1
answer
64
views
Why Visual Studio aborts test of async method returning void instead of Task? [duplicate]
I have an async test method which is not very well written, that it returns void, instead of Task.
[TestMethod]
[DoNotParallelize]
public async void ComponentDrawingAspectParserTest()
{...
2
votes
1
answer
274
views
Getting "Unknown attribute 'MainActor'" when using MainActor with Task
Task { @MainActor // ERROR: Unknown attribute 'MainActor'
handleSuccess(of: response)
}
I thought you can use actors on Tasks. Not sure what I'm doing wrong.
0
votes
0
answers
134
views
SCCM Task Sequence - Powershell (Application Uninstall)
i have created a Task sequence to uninstall a Application via Powershell. i am not able to Find where the issue is. when i Deploy it in Test Device Collection. in Software Center Status shows ...
2
votes
1
answer
313
views
How to execute Quartz jobs in virtual threads
How can I leverage virtual threads to execute I/O-bound Quartz jobs within a Quarkus microservice, handling programmatic job triggering without cron-based scheduling?
We are considering Quartz for our ...
0
votes
2
answers
132
views
try/catch/finally cleanup for tasks that are not awaited
public async Task Handle(HttpContext httpContext, WebSocket socket)
{
using var cts = CancellationTokenSource.CreateLinkedTokenSource(
httpContext.RequestAborted)
try
{
...