chore: fix test hanging

Author: Skn0tt

src/index.ts

@@ -73,6 +73,10 @@ export default class Owl<ScheduleType extends string> {
     return new Activity(this.activityRedis, onEvent, options);
   }
 
+  public async close() {
+    await this.activityRedis?.quit();
+  }
+
   public async runMigrations() {
     const client = this.redisFactory();
     await migrate(client);

test/functional/support.ts

@@ -68,6 +68,7 @@ export function makeProducerEnv(
 
   async function teardown() {
     env.redis.disconnect();
+    await env.owl.close()
     await env.producer.close();
   }
 
@@ -180,7 +181,6 @@ export function makeActivityEnv(backend: Backend, fail?: WorkerFailPredicate) {
 
   activityEnv.teardown = async function teardown() {
     await workerTeardown();
-    await activityEnv.activity.close();
   };
 
   return activityEnv;