diff --git a/Civi/DataProcessor/Factory.php b/Civi/DataProcessor/Factory.php
index cb292583275fdf7e67e70e4706b06069ddd758f6..9bb8b94640415647798f595ef3e7c0e9e5bf3d18 100644
--- a/Civi/DataProcessor/Factory.php
+++ b/Civi/DataProcessor/Factory.php
@@ -108,6 +108,7 @@ class Factory {
     $this->addDataSource('participant', 'Civi\DataProcessor\Source\ParticipantSource', E::ts('Participant'));
     $this->addDataSource('mailing', 'Civi\DataProcessor\Source\MailingSource', E::ts('Mailing'));
     $this->addDataSource('mailing_job', 'Civi\DataProcessor\Source\MailingJobSource', E::ts('Mailing Job'));
+    $this->addDataSource('mailing_group', 'Civi\DataProcessor\Source\MailingGroupSource', E::ts('Mailing Group'));
     $this->addOutput('api', 'Civi\DataProcessor\Output\Api', E::ts('API'));
     $this->addFilter('simple_sql_filter', 'Civi\DataProcessor\FilterHandler\SimpleSqlFilter', E::ts('Simple Filter'));
     $this->addjoinType('simple_join', 'Civi\DataProcessor\DataFlow\MultipleDataFlows\SimpleJoin', E::ts('Simple Join'));
diff --git a/Civi/DataProcessor/Source/AbstractCivicrmEntitySource.php b/Civi/DataProcessor/Source/AbstractCivicrmEntitySource.php
index fa9e0bf69f64be4d0c39077e811a87431646aed6..046b6b775bfbc65b0a400a6367d7ad4c976ebacb 100644
--- a/Civi/DataProcessor/Source/AbstractCivicrmEntitySource.php
+++ b/Civi/DataProcessor/Source/AbstractCivicrmEntitySource.php
@@ -159,7 +159,7 @@ abstract class AbstractCivicrmEntitySource implements SourceInterface {
         continue;
       }
       $type = \CRM_Utils_Type::typeToString($field['type']);
-      $options = $bao::buildOptions($field['name']);
+      $options = $dao::buildOptions($field['name']);
       $alias = $this->getSourceName(). '_'.$field['name'];
       $fieldSpec = new FieldSpecification($field['name'], $type, $field['title'], $options, $alias);
       $dataSpecification->addFieldSpecification($fieldSpec->name, $fieldSpec);
diff --git a/Civi/DataProcessor/Source/MailingGroupSource.php b/Civi/DataProcessor/Source/MailingGroupSource.php
new file mode 100644
index 0000000000000000000000000000000000000000..41f5b33207a27e9ec9c3e3a43b5474f2a457399f
--- /dev/null
+++ b/Civi/DataProcessor/Source/MailingGroupSource.php
@@ -0,0 +1,35 @@
+<?php
+/**
+ * @author Jaap Jansma <jaap.jansma@civicoop.org>
+ * @license AGPL-3.0
+ */
+
+namespace Civi\DataProcessor\Source;
+
+use Civi\DataProcessor\DataFlow\SqlTableDataFlow;
+use Civi\DataProcessor\DataSpecification\DataSpecification;
+use Civi\DataProcessor\DataSpecification\FieldSpecification;
+
+use CRM_Dataprocessor_ExtensionUtil as E;
+
+class MailingGroupSource extends AbstractCivicrmEntitySource {
+
+  /**
+   * Returns the entity name
+   *
+   * @return String
+   */
+  protected function getEntity() {
+    return 'MailingGroup';
+  }
+
+  /**
+   * Returns the table name of this entity
+   *
+   * @return String
+   */
+  protected function getTable() {
+    return 'civicrm_mailing_group';
+  }
+
+}
\ No newline at end of file