Function DropTask

src/backend/commands/taskcmds.c:296–326

* DropTask * Drop an existing cron task. */

 *      Drop an existing cron task.
 */
ObjectAddress
DropTask(ParseState *pstate, DropTaskStmt * stmt)
{
	ObjectAddress address = InvalidObjectAddress;
	char	   *username;
	Oid			jobid = InvalidOid;

	/* current username */
	username = GetUserNameFromId(GetUserId(), false);

	/* delete from pg_task */
	jobid = UnscheduleCronJob(stmt->taskname, username, InvalidOid, stmt->missing_ok);

	/* delete from pg_task_run_history according to the jobid */
	if (OidIsValid(jobid))
	{
		if (!allowSystemTableMods && strncmp(stmt->taskname, DYNAMIC_TASK_PREFIX, 25) == 0)
		{
			ereport(ERROR,
					(errcode(ERRCODE_RESERVED_NAME),
					 errmsg("can not drop a internal task \"%s\" paried with dynamic table", stmt->taskname),
					 errdetail("please drop the dynamic table instead")));
		}
		RemoveTaskRunHistoryByJobId(jobid);
		ObjectAddressSet(address, TaskRelationId, jobid);
		/* Clean up dependencies */
		deleteSharedDependencyRecordsFor(TaskRelationId, jobid, 0);
	}

	return address;
}

/*
 * RemoveTaskById