':param project: the GCP project name or ID in which to work
(templated)
:type project: string
:param topic: the topic to create. Do not include the
full topic path. In other words, instead of
``projects/{project}/topics/{topic}``, provide only
``{topic}``. (templated)
:type topic: string
:param gcp_conn_id: The connection ID to use connecting to
Google Cloud Platform.
:type gcp_conn_id: string
:param delegate_to: The account to impersonate, if any.
For this to work, the service account making the request
must have domain-wide delegation enabled.
:type delegate_to: string'

@apply_defaults
def __init__(self, project, topic, fail_if_exists=False, gcp_conn_id='google_cloud_default', delegate_to=None, *args, **kwargs):

    super(PubSubTopicCreateOperator, self).__init__(*args, **kwargs)
    self.project = project
    self.topic = topic
    self.fail_if_exists = fail_if_exists
    self.gcp_conn_id = gcp_conn_id
    self.delegate_to = delegate_to
