change consumer to durable

internal/adapters/natsadapter/natsadapter.go

@@ -118,7 +118,9 @@ func (na *NatsAdapter) ConsumeQueue(
 	ctx context.Context,
 	taskFunc func(taskPayload []byte) (cacheKey string, result []byte, err error),
 ) error {
-	cons, err := na.jstream.CreateOrUpdateConsumer(ctx, jetstream.ConsumerConfig{})
+	cons, err := na.jstream.CreateOrUpdateConsumer(ctx, jetstream.ConsumerConfig{
+		Durable: "worker",
+	})
 	if err != nil {
 		return fmt.Errorf("create js consumer: %w", err)
 	}
@@ -147,7 +149,7 @@ func (na *NatsAdapter) ConsumeQueue(
 
 		if taskErr != nil {
 			log.Errorf("taskFunc seq=%d error, discarding task: %v", seq, taskErr)
-			if err := msg.Nak(); err != nil {
+			if err := msg.Term(); err != nil {
 				log.Errorf("nak %d: %v", seq, err)
 			}
 			return

internal/extractors/pwextractor/pwextractor.go

@@ -161,7 +161,6 @@ func (p *pageParser) parse() (*models.TaskResult, error) {
 func (p *pageParser) waitFullLoad() {
 	timeout := pwDuration("5s")
 	ctx, cancel := context.WithCancel(context.Background())
-	defer cancel()
 
 	go func() {
 		err := p.page.WaitForLoadState(playwright.PageWaitForLoadStateOptions{