gstlal_ll_inspiral_event_plotter: add a separate job to the DAG for plotting injection events

We've observed an issue with the event plotter job where not every event uploaded to GraceDB has plots associated with it, especially if there are multiple events at the same time.

The way the job works is that it receives Kafka messages for each GraceDB event and loops over those received messages producing plots to upload to the event. However, making all the plots can take several minutes and since messages only stay in Kafka for 100 seconds, I believe sometimes the program is missing messages, ie it's unable to consume new messages while it's in the process of handling previous messages.

The first pass solution to this is to make a duplicate plotter job in the DAG so that we have one to process non-injection events and one to process injection events. This will also be more consistent with how we've separated injection and non-injection processing in the rest of the workflow. This MR adds the separate job and makes associated changes to upstream programs (gstlal_inspiral, gstlal_ll_inspiral_event_uploader) to send data to separate inj and non-inj topics.

gstlal-inspiral/bin/gstlal_ll_inspiral_event_plotter

@@ -94,6 +94,8 @@ def parse_command_line():
 	parser.add_option('--processing-cadence', type = 'float', default = 0.1, help = 'Rate at which the event plotter acquires and processes data. Default = 0.1 seconds.')
 	parser.add_option('--request-timeout', type = 'float', default = 0.2, help = 'Timeout for requesting messages from a topic. Default = 0.2 seconds.')
 	parser.add_option('--kafka-server', metavar = 'string', help = 'Sets the server url that the kafka topic is hosted on. Required.')
+	parser.add_option("--upload-topic", metavar = "string", help = "Sets the input kafka topic to get uploaded event info from. Required.")
+	parser.add_option("--ranking-stat-topic", metavar = "string", help = "Sets the input kafka topic to get ranking stat info from. Required.")
 	parser.add_option('--gracedb-group', metavar = 'name', default = 'Test', help = 'Gracedb group to which to upload events (default is Test).')
 	parser.add_option('--gracedb-pipeline', metavar = 'name', default = 'gstlal', help = 'Name of pipeline to provide in GracedB uploads (default is gstlal).')
 	parser.add_option('--gracedb-search', metavar = 'name', default = 'LowMass', help = 'Name of search to provide in GracedB uploads (default is LowMass).')
@@ -123,8 +125,8 @@ class EventPlotter(events.EventProcessor):
 	def __init__(self, options):
 		logging.info('setting up event plotter...')
 
-		self.upload_topic = f'gstlal.{options.tag}.uploads'
-		self.ranking_stat_topic = f'gstlal.{options.tag}.ranking_stat'
+		self.upload_topic = f'gstlal.{options.tag}.{options.upload_topic}'
+		self.ranking_stat_topic = f'gstlal.{options.tag}.{options.ranking_stat_topic}'
 		events.EventProcessor.__init__(
 			self,
 			process_cadence=options.processing_cadence,