diff --git a/recon/masscan.py b/recon/masscan.py
index aa83926..a0a9350 100644
--- a/recon/masscan.py
+++ b/recon/masscan.py
@@ -1,18 +1,19 @@
 import json
 import pickle
 import logging
+import subprocess
 from collections import defaultdict
 
 import luigi
 from luigi.util import inherits
-from luigi.contrib.external_program import ExternalProgramTask
 
 from recon.targets import TargetList
+from recon.amass import ParseAmassOutput
 from recon.config import top_tcp_ports, top_udp_ports, masscan_config
 
 
-@inherits(TargetList)
-class Masscan(ExternalProgramTask):
+@inherits(TargetList, ParseAmassOutput)
+class Masscan(luigi.Task):
     """ Run masscan against a target specified via the TargetList Task.
 
     Masscan commands are structured like the example below.  When specified, --top_ports is processed and
@@ -30,6 +31,7 @@ class Masscan(ExternalProgramTask):
         top_ports: Scan top N most popular ports
         ports: specifies the port(s) to be scanned
         target_file: specifies the file on disk containing a list of ips or domains *--* Required by upstream Task
+        exempt_list: Path to a file providing blacklisted subdomains, one per line. *--* Optional for upstream Task
     """
 
     rate = luigi.Parameter(default=masscan_config.get("rate"))
@@ -41,16 +43,6 @@ class Masscan(ExternalProgramTask):
         super(Masscan, self).__init__(*args, **kwargs)
         self.masscan_output = f"masscan.{self.target_file}.json"
 
-    def requires(self):
-        """ Masscan depends on TargetList to run.
-
-        TargetList expects target_file as a parameter.
-
-        Returns:
-            luigi.ExternalTask - TargetList
-        """
-        return TargetList(target_file=self.target_file)
-
     def output(self):
         """ Returns the target output for this task.
 
@@ -61,7 +53,7 @@ class Masscan(ExternalProgramTask):
         """
         return luigi.LocalTarget(self.masscan_output)
 
-    def program_args(self):
+    def run(self):
         """ Defines the options/arguments sent to masscan after processing.
 
         Returns:
@@ -90,6 +82,11 @@ class Masscan(ExternalProgramTask):
             self.ports = f"{top_tcp_ports_str},U:{top_udp_ports_str}"
             self.top_ports = 0
 
+        target_list = yield TargetList(target_file=self.target_file)
+
+        if target_list.path.endswith("domains"):
+            yield ParseAmassOutput(target_file=self.target_file, exempt_list=self.exempt_list)
+
         command = [
             "masscan",
             "-v",
@@ -104,10 +101,10 @@ class Masscan(ExternalProgramTask):
             "--ports",
             self.ports,
             "-iL",
-            self.input().path,
+            target_list.path.replace("domains", "ips"),
         ]
 
-        return command
+        subprocess.run(command)
 
 
 @inherits(Masscan)