Events - Timeouts -Task Cleanup

Author: mateeullahmalik

pkg/common/task/worker.go

@@ -109,10 +109,15 @@ func NewWorker() *Worker {
 }
 
 // cleanupLoop periodically removes tasks that are in a final state for a grace period
+// or any task that has been around for too long
 func (worker *Worker) cleanupLoop(ctx context.Context) {
 	const (
 		cleanupInterval = 30 * time.Second
 		finalTaskTTL    = 2 * time.Minute
+		// maxTaskAge removes any task entry after this age, regardless of state.
+		// Keep greater than the largest server-side task envelope (RegisterTimeout ~75m)
+		// to avoid pruning legitimate long-running tasks from the worker registry.
+		maxTaskAge = 2 * time.Hour
 	)
 
 	ticker := time.NewTicker(cleanupInterval)
@@ -129,11 +134,17 @@ func (worker *Worker) cleanupLoop(ctx context.Context) {
 			kept := worker.tasks[:0]
 			for _, t := range worker.tasks {
 				st := t.Status()
-				if st != nil && st.SubStatus != nil && st.SubStatus.IsFinal() {
-					if now.Sub(st.CreatedAt) >= finalTaskTTL {
-						// drop this finalized task
+				if st != nil {
+					// Remove any task older than 30 minutes, regardless of state
+					if now.Sub(st.CreatedAt) >= maxTaskAge {
 						continue
 					}
+					// Also remove final tasks after 2 minutes
+					if st.SubStatus != nil && st.SubStatus.IsFinal() {
+						if now.Sub(st.CreatedAt) >= finalTaskTTL {
+							continue
+						}
+					}
 				}
 				kept = append(kept, t)
 			}

sdk/README.md

@@ -221,6 +221,12 @@ if err != nil {
 // taskID can be used to track the download progress
 ```
 
+Behavior notes:
+- The SDK determines the final filename from on-chain cascade metadata and creates the path: `outputDir/<actionID>/<filename>`.
+- Events will include both the supernode endpoint (`event.KeySupernode`) and its Cosmos address (`event.KeySupernodeAddress`).
+- On success, both `SDKOutputPathReceived` and `SDKDownloadSuccessful` include `event.KeyOutputPath`.
+- Failures include reason-coded suffixes in the message (e.g., `| reason=timeout`) and set `event.KeyMessage` accordingly.
+
 **Parameters:**
 - `ctx context.Context`: Context for the operation
 - `actionID string`: ID of the action to download
@@ -381,7 +387,7 @@ The SDK provides an event system to monitor task progress through event subscrip
 - `SDKRegistrationAttempt`: Attempting to register with a supernode
 - `SDKRegistrationFailure`: Registration with supernode failed
 - `SDKRegistrationSuccessful`: Successfully registered with supernode
-- `SDKTaskTxHashReceived`: Transaction hash received from supernode
+- `SDKTaskTxHashReceived`: Transaction hash received from supernode (includes endpoint in `KeySupernode` and Cosmos address in `KeySupernodeAddress`)
 - `SDKTaskCompleted`: Task completed successfully
 - `SDKTaskFailed`: Task failed with error
  - `SDKConnectionEstablished`: Connection to supernode established
@@ -392,9 +398,9 @@ The SDK provides an event system to monitor task progress through event subscrip
  - `SDKProcessingFailed`: Processing failed (reason=stream_recv|missing_final_response)
  - `SDKProcessingTimeout`: Processing exceeded time budget and was cancelled
 - `SDKDownloadAttempt`: Attempting to download from supernode
-- `SDKDownloadFailure`: Download attempt failed
-- `SDKOutputPathReceived`: File download path received
-- `SDKDownloadSuccessful`: Download completed successfully
+- `SDKDownloadFailure`: Download attempt failed (message may include `| reason=timeout|canceled`; `KeyMessage` mirrors the reason)
+- `SDKOutputPathReceived`: File download path received (includes `KeyOutputPath` and supernode identity keys)
+- `SDKDownloadSuccessful`: Download completed successfully (includes `KeyOutputPath` and supernode identity keys)
 
 **Supernode Events (forwarded from supernodes):**
 - `SupernodeActionRetrieved`: Action retrieved from blockchain
@@ -421,8 +427,8 @@ Events may include additional data accessible through these keys:
 
 - `event.KeyError`: Error message (for failure events)
 - `event.KeyCount`: Count of items (e.g., supernodes found)
-- `event.KeySupernode`: Supernode endpoint
-- `event.KeySupernodeAddress`: Supernode cosmos address
+- `event.KeySupernode`: Supernode gRPC endpoint
+- `event.KeySupernodeAddress`: Supernode Cosmos address
 - `event.KeyIteration`: Attempt iteration number
 - `event.KeyTxHash`: Transaction hash
 - `event.KeyMessage`: Event message