@job<EOL>def worker(wrapped, dkwargs, hash_value=None, *args, **kwargs):
if "<STR_LIT>" not in dkwargs:<EOL><INDENT>msg = "<STR_LIT>"<EOL>raise TypeError(msg)<EOL><DEDENT>event = dkwargs['<STR_LIT>']<EOL>if "<STR_LIT>" not in kwargs:<EOL><INDENT>msg = "<STR_LIT>"<EOL>raise TypeError(msg)<EOL><DEDENT>owner = kwargs['<STR_LIT>']<EOL>if "<STR_LIT>" not in kwargs:<EOL><INDENT>msg = "<STR_LIT>"<EOL>raise TypeError(msg)<EOL><DEDENT>identifier = kwargs['<STR_LIT>']<EOL>senderobj = DjangoRQSenderable(<EOL>wrapped, dkwargs, hash_value, WEBHOOK_ATTEMPTS, *args, **kwargs<EOL>)<EOL>senderobj.webhook_target = WebhookTarget.objects.get(<EOL>event=event,<EOL>owner=owner,<EOL>identifier=identifier<EOL>)<EOL>senderobj.url = senderobj.webhook_target.target_url<EOL>senderobj.payload = senderobj.get_payload()<EOL>senderobj.payload['<STR_LIT>'] = getattr(kwargs['<STR_LIT>'], WEBHOOK_OWNER_FIELD)<EOL>senderobj.payload['<STR_LIT>'] = dkwargs['<STR_LIT>']<EOL>return senderobj.send()<EOL>
This is an asynchronous sender callable that uses the Django ORM to store
    webhooks. Redis is used to handle the message queue.

dkwargs argument requires the following key/values:

    :event: A string representing an event.

kwargs argument requires the following key/values

    :owner: The user who created/owns the event